public static <K, V> KafkaConsumer<K, V> createKafkaConsumerImpl(String systemName, HashMap<String, Object> kafkaConsumerConfig) {
    LOG.info("Instantiating KafkaConsumer for systemName {} with properties {}", systemName, kafkaConsumerConfig);
    return new KafkaConsumer<>(kafkaConsumerConfig);
  }
Create internal kafka consumer object, which will be used in the Proxy.
@param <K> key type for the consumer
@param <V> value type for the consumer
@param systemName system name for which we create the consumer
@param kafkaConsumerConfig config object for Kafka's KafkaConsumer
@return KafkaConsumer newly created kafka consumer object
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsumer.java