java.lang.Object listener
org.apache.kafka.clients.consumer.Consumer<K,V> kafkaConsumer
org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord