public interface Consumer<K,V> extends Closeable
KafkaConsumer
,
MockConsumer
Set<TopicPartition> assignment()
KafkaConsumer.assignment()
Set<String> subscription()
KafkaConsumer.subscription()
void subscribe(Collection<String> topics)
KafkaConsumer.subscribe(Collection)
void subscribe(Collection<String> topics, ConsumerRebalanceListener callback)
void assign(Collection<TopicPartition> partitions)
KafkaConsumer.assign(Collection)
void subscribe(Pattern pattern, ConsumerRebalanceListener callback)
void unsubscribe()
KafkaConsumer.unsubscribe()
ConsumerRecords<K,V> poll(long timeout)
KafkaConsumer.poll(long)
void commitSync()
KafkaConsumer.commitSync()
void commitSync(Map<TopicPartition,OffsetAndMetadata> offsets)
KafkaConsumer.commitSync(Map)
void commitAsync()
KafkaConsumer.commitAsync()
void commitAsync(OffsetCommitCallback callback)
void commitAsync(Map<TopicPartition,OffsetAndMetadata> offsets, OffsetCommitCallback callback)
void seek(TopicPartition partition, long offset)
void seekToBeginning(Collection<TopicPartition> partitions)
void seekToEnd(Collection<TopicPartition> partitions)
KafkaConsumer.seekToEnd(Collection)
long position(TopicPartition partition)
OffsetAndMetadata committed(TopicPartition partition)
Map<MetricName,? extends Metric> metrics()
KafkaConsumer.metrics()
List<PartitionInfo> partitionsFor(String topic)
KafkaConsumer.partitionsFor(String)
Map<String,List<PartitionInfo>> listTopics()
KafkaConsumer.listTopics()
Set<TopicPartition> paused()
KafkaConsumer.paused()
void pause(Collection<TopicPartition> partitions)
KafkaConsumer.pause(Collection)
void resume(Collection<TopicPartition> partitions)
KafkaConsumer.resume(Collection)
void close()
close
in interface AutoCloseable
close
in interface Closeable
KafkaConsumer.close()
void wakeup()
KafkaConsumer.wakeup()