public interface MessageListener
void
onMessage(KafkaMessage message)
void onMessage(KafkaMessage message)
message