All Methods Instance Methods Abstract Methods Deprecated Methods
Modifier and Type |
Method |
Description |
void |
assign(Collection<TopicPartition> partitions) |
|
Set<TopicPartition> |
assignment() |
|
Map<TopicPartition,Long> |
beginningOffsets(Collection<TopicPartition> partitions) |
|
Map<TopicPartition,Long> |
beginningOffsets(Collection<TopicPartition> partitions,
Duration timeout) |
|
void |
close() |
|
void |
close(Duration timeout) |
|
void |
commitAsync() |
|
void |
commitAsync(Map<TopicPartition,OffsetAndMetadata> offsets,
OffsetCommitCallback callback) |
|
void |
commitAsync(OffsetCommitCallback callback) |
|
void |
commitSync() |
|
void |
commitSync(Duration timeout) |
|
void |
commitSync(Map<TopicPartition,OffsetAndMetadata> offsets) |
|
void |
commitSync(Map<TopicPartition,OffsetAndMetadata> offsets,
Duration timeout) |
|
Map<TopicPartition,OffsetAndMetadata> |
committed(Set<TopicPartition> partitions) |
|
Map<TopicPartition,OffsetAndMetadata> |
committed(Set<TopicPartition> partitions,
Duration timeout) |
|
OffsetAndMetadata |
committed(TopicPartition partition) |
Deprecated.
|
OffsetAndMetadata |
committed(TopicPartition partition,
Duration timeout) |
Deprecated.
|
OptionalLong |
currentLag(TopicPartition topicPartition) |
|
Map<TopicPartition,Long> |
endOffsets(Collection<TopicPartition> partitions) |
|
Map<TopicPartition,Long> |
endOffsets(Collection<TopicPartition> partitions,
Duration timeout) |
|
void |
enforceRebalance() |
|
void |
enforceRebalance(String reason) |
|
ConsumerGroupMetadata |
groupMetadata() |
|
Map<String,List<PartitionInfo>> |
listTopics() |
|
Map<String,List<PartitionInfo>> |
listTopics(String stream) |
|
Map<String,List<PartitionInfo>> |
listTopics(String stream,
Duration timeout) |
|
Map<String,List<PartitionInfo>> |
listTopics(Duration timeout) |
|
Map<String,List<PartitionInfo>> |
listTopics(Pattern pattern) |
|
Map<String,List<PartitionInfo>> |
listTopics(Pattern pattern,
Duration timeout) |
|
Map<MetricName,? extends Metric> |
metrics() |
|
Map<TopicPartition,OffsetAndTimestamp> |
offsetsForTimes(Map<TopicPartition,Long> timestampsToSearch) |
|
Map<TopicPartition,OffsetAndTimestamp> |
offsetsForTimes(Map<TopicPartition,Long> timestampsToSearch,
Duration timeout) |
|
List<PartitionInfo> |
partitionsFor(String topic) |
|
List<PartitionInfo> |
partitionsFor(String topic,
Duration timeout) |
|
void |
pause(Collection<TopicPartition> partitions) |
|
Set<TopicPartition> |
paused() |
|
ConsumerRecords<K,V> |
poll(long timeout) |
Deprecated.
|
ConsumerRecords<K,V> |
poll(Duration timeout) |
|
long |
position(TopicPartition partition) |
|
long |
position(TopicPartition partition,
Duration timeout) |
|
void |
resume(Collection<TopicPartition> partitions) |
|
void |
seek(TopicPartition partition,
long offset) |
|
void |
seek(TopicPartition partition,
OffsetAndMetadata offsetAndMetadata) |
|
void |
seekToBeginning(Collection<TopicPartition> partitions) |
|
void |
seekToEnd(Collection<TopicPartition> partitions) |
|
void |
subscribe(Collection<String> topics) |
|
void |
subscribe(Collection<String> topics,
ConsumerRebalanceListener callback) |
|
void |
subscribe(Pattern pattern) |
|
void |
subscribe(Pattern pattern,
ConsumerRebalanceListener callback) |
|
Set<String> |
subscription() |
|
void |
unsubscribe() |
|
void |
wakeup() |
|