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>
- Author:
- Gary Russell, Murali Reddy, Artem Bilan, Chris Gilbert, Adrian Gygax, Yaniv Nahoum, Sanghyeok An, Borahm Lee
-
Constructor Summary
Constructors -
Method Summary
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
-
Constructor Details
-
ExtendedKafkaConsumer
-
-
Method Details
-
close
-
close
-