クラス DefaultKafkaConsumerFactory.ExtendedKafkaConsumer

java.lang.ObjectSE
org.apache.kafka.clients.consumer.KafkaConsumer<K,V>
org.springframework.kafka.core.DefaultKafkaConsumerFactory.ExtendedKafkaConsumer
実装されているすべてのインターフェース:
CloseableSE、AutoCloseableSE、org.apache.kafka.clients.consumer.Consumer<K,V>
含まれているクラス:
DefaultKafkaConsumerFactory<K,V>
protected class DefaultKafkaConsumerFactory.ExtendedKafkaConsumer extends org.apache.kafka.clients.consumer.KafkaConsumer<K,V>
作成者:
Gary Russell, Murali Reddy, Artem Bilan, Chris Gilbert, Adrian Gygax, Yaniv Nahoum, Sanghyeok An, Borahm Lee, Soby Chacko

  • コンストラクターの概要

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

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    close()
    void
    close(org.apache.kafka.clients.consumer.CloseOptions option)

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

    assign, assignment, beginningOffsets, beginningOffsets, clientInstanceId, close, commitAsync, commitAsync, commitAsync, commitSync, commitSync, commitSync, commitSync, committed, committed, currentLag, endOffsets, endOffsets, enforceRebalance, enforceRebalance, groupMetadata, listTopics, listTopics, metrics, offsetsForTimes, offsetsForTimes, partitionsFor, partitionsFor, pause, paused, poll, position, position, registerMetricForSubscription, resume, seek, seek, seekToBeginning, seekToEnd, subscribe, subscribe, subscribe, subscribe, subscribe, 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.Consumer<K,V> の close 
      オーバーライド:
      クラス org.apache.kafka.clients.consumer.KafkaConsumer<K,V> の close 

    • close

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