public interface ConsumerListener<K,V>
Modifier and Type | Method and Description |
---|---|
void |
onConsumerRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
V oldValue)
Notification of new record consumed by local reader
|