public KafkaConsumerProxy<K, V> create(KafkaSystemConsumer<K, V> kafkaSystemConsumer) {
      String metricName = String.format("%s-%s", systemName, clientId);
      return new KafkaConsumerProxy<>(kafkaSystemConsumer, this.kafkaConsumer, this.systemName, this.clientId, kafkaSystemConsumer.getMessageSink(),
          this.kafkaSystemConsumerMetrics, metricName);
    }
Used to create an instance of {@link KafkaConsumerProxy}. This can be overridden in case an extension of
{@link KafkaConsumerProxy} needs to be used within kafka system components like {@link KafkaSystemConsumer}.
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaConsumerProxy.java