code: public static KafkaConsumer<String, byte[]> createKafkaConsumer(String bootstrapServers,
              String consumerGroupId, boolean consumeFromBeginning, boolean autoCommitOffsets,
              Properties customProps) {
          Properties props = buildKafkaConsumerProps(bootstrapServers, consumerGroupId,
                  consumeFromBeginning, autoCommitOffsets, customProps);
          KafkaConsumer<String, byte[]> consumer = new KafkaConsumer<String, byte[]>(props);
          return consumer;
      }
docs: Creates a new {@link KafkaConsumer} instance, with custom configuration
  properties.
  
  <p>
  Note: custom configuration properties will be populated <i>after</i> and
  <i>additional/overridden</i> to the default configuration.
  </p>
  
  @param bootstrapServers
  @param consumerGroupId
  @param consumeFromBeginning
  @param autoCommitOffsets
  @param customProps
  @return
  @since 1.2.1