public KafkaConsumerMessageSink getMessageSink() {
    return this.messageSink;
  }
return system name for this consumer
@return system name
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsumer.java