code: public static KafkaConsumer<String, byte[]> createKafkaConsumer(String bootstrapServers,
              String consumerGroupId, boolean consumeFromBeginning, boolean autoCommitOffsets) {
          return createKafkaConsumer(bootstrapServers, consumerGroupId, consumeFromBeginning,
                  autoCommitOffsets, null);
      }
docs: Creates a new {@link KafkaConsumer} instance, with default
  configurations.
  
  @param bootstrapServers
  @param consumerGroupId
  @param consumeFromBeginning
  @param autoCommitOffsets
  @return