io.confluent.security.store.kafka.clients

Interface ConsumerListener<K,V>

All Known Implementing Classes:

AuthnzAuthStore, DataplaneAuthStore, DataplaneBaseAuthStore, KafkaAuthStore, KafkaAuthWriter

public interface ConsumerListener<K,V>

Method Summary

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

Method Detail

onConsumerRecord

void onConsumerRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
                      V oldValue)

Notification of new record consumed by local reader

Parameters:

record - the record from consumer

oldValue - old value corresponding to record key from local cache