Package io.confluent.security.store.kafka.clients

Interface ConsumerListener<K,V>

All Known Implementing Classes:
AuthnzAuthStore, DataplaneAuthStore, DataplaneBaseAuthStore, IpFilteringAuthStore, KafkaAuthStore, KafkaAuthWriter
public interface ConsumerListener<K,V>

  • Method Summary

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

  • Method Details

    • 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