public interface Consumer<K,V>
extends java.io.Closeable
KafkaConsumer
,
MockConsumer
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
commit(CommitType commitType) |
void |
commit(java.util.Map<TopicPartition,java.lang.Long> offsets,
CommitType commitType) |
long |
committed(TopicPartition partition) |
java.util.Map<MetricName,? extends Metric> |
metrics() |
java.util.List<PartitionInfo> |
partitionsFor(java.lang.String topic) |
ConsumerRecords<K,V> |
poll(long timeout) |
long |
position(TopicPartition partition) |
void |
seek(TopicPartition partition,
long offset) |
void |
seekToBeginning(TopicPartition... partitions) |
void |
seekToEnd(TopicPartition... partitions) |
void |
subscribe(java.lang.String... topics) |
void |
subscribe(TopicPartition... partitions) |
java.util.Set<TopicPartition> |
subscriptions() |
void |
unsubscribe(java.lang.String... topics) |
void |
unsubscribe(TopicPartition... partitions) |
java.util.Set<TopicPartition> subscriptions()
KafkaConsumer.subscriptions()
void subscribe(java.lang.String... topics)
KafkaConsumer.subscribe(String...)
void subscribe(TopicPartition... partitions)
void unsubscribe(java.lang.String... topics)
KafkaConsumer.unsubscribe(String...)
void unsubscribe(TopicPartition... partitions)
ConsumerRecords<K,V> poll(long timeout)
KafkaConsumer.poll(long)
void commit(CommitType commitType)
KafkaConsumer.commit(CommitType)
void commit(java.util.Map<TopicPartition,java.lang.Long> offsets, CommitType commitType)
void seek(TopicPartition partition, long offset)
void seekToBeginning(TopicPartition... partitions)
void seekToEnd(TopicPartition... partitions)
long position(TopicPartition partition)
long committed(TopicPartition partition)
java.util.Map<MetricName,? extends Metric> metrics()
KafkaConsumer.metrics()
java.util.List<PartitionInfo> partitionsFor(java.lang.String topic)
KafkaConsumer.partitionsFor(String)
void close()
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable
KafkaConsumer.close()