パッケージ org.springframework.kafka.core

クラス 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>

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

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

  • メソッドのサマリー

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

    クラス 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

    クラス 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(DurationSE timeout)
      次で指定:
      インターフェース org.apache.kafka.clients.consumer.Consumer<K,V> の close 
      オーバーライド:
      クラス org.apache.kafka.clients.consumer.KafkaConsumer<K,V> の close