K
V
public interface MessageListener<K,V>
void
onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
ConsumerRecord
void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
record