Class KafkaConsumerInterceptor

java.lang.Object
org.chenile.pubsub.kafka.interceptor.KafkaConsumerInterceptor
All Implemented Interfaces:
AutoCloseable, org.apache.kafka.clients.consumer.ConsumerInterceptor<String,String>, org.apache.kafka.common.Configurable
public class KafkaConsumerInterceptor extends Object implements org.apache.kafka.clients.consumer.ConsumerInterceptor<String,String>

  • Field Details

    • logger

      private static final org.slf4j.Logger logger

    • messageCount

      private static final AtomicInteger messageCount

  • Constructor Details

    • KafkaConsumerInterceptor

      public KafkaConsumerInterceptor()

  • Method Details

    • getMessageCount

      public static int getMessageCount()

    • onConsume

      public org.apache.kafka.clients.consumer.ConsumerRecords<String,String> onConsume(org.apache.kafka.clients.consumer.ConsumerRecords<String,String> records)
      Specified by:
      onConsume in interface org.apache.kafka.clients.consumer.ConsumerInterceptor<String,String>

    • onCommit

      public void onCommit(Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
      Specified by:
      onCommit in interface org.apache.kafka.clients.consumer.ConsumerInterceptor<String,String>

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface org.apache.kafka.clients.consumer.ConsumerInterceptor<String,String>

    • configure

      public void configure(Map<String,?> configs)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable