クラス DefaultShareConsumerFactory.ExtendedShareConsumer

java.lang.ObjectSE
org.apache.kafka.clients.consumer.KafkaShareConsumer<K,V>
org.springframework.kafka.core.DefaultShareConsumerFactory.ExtendedShareConsumer
実装済みのインターフェース一覧:
CloseableSE、AutoCloseableSE、org.apache.kafka.clients.consumer.ShareConsumer<K,V>
含まれているクラス:
DefaultShareConsumerFactory<K,V>
protected class DefaultShareConsumerFactory.ExtendedShareConsumer extends org.apache.kafka.clients.consumer.KafkaShareConsumer<K,V>
導入:
4.0
作成者:
Soby Chacko

  • コンストラクター概要

    コンストラクター
    修飾子
    コンストラクター
    説明
    protected
    ExtendedShareConsumer(MapSE<StringSE,ObjectSE> configProps)

  • 方法の概要

    修飾子と型
    メソッド
    説明
    void
    close()
    void
    close(DurationSE timeout)

    クラス org.apache.kafka.clients.consumer.KafkaShareConsumer から継承されたメソッド

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

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

  • コンストラクターの詳細

  • メソッドの詳細

    • close

      public void close()
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース CloseableSE の close 
      次で指定:
      インターフェース org.apache.kafka.clients.consumer.ShareConsumer<K,V> の close 
      オーバーライド:
      クラス org.apache.kafka.clients.consumer.KafkaShareConsumer<K,V> の close 

    • close

      public void close(DurationSE timeout)
      次で指定:
      インターフェース org.apache.kafka.clients.consumer.ShareConsumer<K,V> の close 
      オーバーライド:
      クラス org.apache.kafka.clients.consumer.KafkaShareConsumer<K,V> の close