Class DefaultShareConsumerFactory.ExtendedShareConsumer

java.lang.Object
org.apache.kafka.clients.consumer.KafkaShareConsumer<K,V>
org.springframework.kafka.core.DefaultShareConsumerFactory.ExtendedShareConsumer
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.clients.consumer.ShareConsumer<K,V>
Enclosing class:
DefaultShareConsumerFactory<K,V>
protected class DefaultShareConsumerFactory.ExtendedShareConsumer extends org.apache.kafka.clients.consumer.KafkaShareConsumer<K,V>
Since:
4.0
Author:
Soby Chacko

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    ExtendedShareConsumer(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.KafkaShareConsumer

    acknowledge, acknowledge, clientInstanceId, commitAsync, commitSync, commitSync, metrics, poll, registerMetricForSubscription, setAcknowledgementCommitCallback, subscribe, subscription, unregisterMetricFromSubscription, unsubscribe, wakeup

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ExtendedShareConsumer

      protected ExtendedShareConsumer(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.ShareConsumer<K,V>
      Overrides:
      close in class org.apache.kafka.clients.consumer.KafkaShareConsumer<K,V>

    • close

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