Package org.springframework.kafka.core

Class DefaultKafkaConsumerFactory.ExtendedKafkaConsumer

java.lang.Object
org.apache.kafka.clients.consumer.KafkaConsumer<K,V>
org.springframework.kafka.core.DefaultKafkaConsumerFactory.ExtendedKafkaConsumer
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.clients.consumer.Consumer<K,V>
Enclosing class:
DefaultKafkaConsumerFactory<K,V>
protected class DefaultKafkaConsumerFactory.ExtendedKafkaConsumer extends org.apache.kafka.clients.consumer.KafkaConsumer<K,V>

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    ExtendedKafkaConsumer(Map<String,Object> configProps)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    void
    close(Duration timeout)
     

    Methods inherited from class org.apache.kafka.clients.consumer.KafkaConsumer

    assign, assignment, beginningOffsets, beginningOffsets, clientInstanceId, commitAsync, commitAsync, commitAsync, commitSync, commitSync, commitSync, commitSync, committed, committed, committed, committed, currentLag, endOffsets, endOffsets, enforceRebalance, enforceRebalance, groupMetadata, listTopics, listTopics, metrics, offsetsForTimes, offsetsForTimes, partitionsFor, partitionsFor, pause, paused, poll, poll, position, position, resume, seek, seek, seekToBeginning, seekToEnd, subscribe, subscribe, subscribe, subscribe, subscription, unsubscribe, wakeup

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ExtendedKafkaConsumer

      protected ExtendedKafkaConsumer(Map<String,Object> configProps)

  • Method Details

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.kafka.clients.consumer.Consumer<K,V>
      Overrides:
      close in class org.apache.kafka.clients.consumer.KafkaConsumer<K,V>

    • close

      public void close(Duration timeout)
      Specified by:
      close in interface org.apache.kafka.clients.consumer.Consumer<K,V>
      Overrides:
      close in class org.apache.kafka.clients.consumer.KafkaConsumer<K,V>