| Modifier and Type | Method and Description |
|---|---|
default Future<Map<TopicPartition,OffsetAndMetadata>> |
KafkaAdminClient.listConsumerGroupOffsets(String groupId)
Like
KafkaAdminClient.listConsumerGroupOffsets(String, Handler) but returns a Future of the asynchronous result |
Future<Map<TopicPartition,OffsetAndMetadata>> |
KafkaAdminClient.listConsumerGroupOffsets(String groupId,
ListConsumerGroupOffsetsOptions options)
Like
KafkaAdminClient.listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
KafkaAdminClient.alterConsumerGroupOffsets(String groupId,
Map<TopicPartition,OffsetAndMetadata> offsets)
Like
KafkaAdminClient.alterConsumerGroupOffsets(String, Map, Handler) but returns a Future of the asynchronous result |
void |
KafkaAdminClient.alterConsumerGroupOffsets(String groupId,
Map<TopicPartition,OffsetAndMetadata> offsets,
Handler<AsyncResult<Void>> completionHandler)
Alter committed offsets for a set of partitions in a consumer group.
|
default void |
KafkaAdminClient.listConsumerGroupOffsets(String groupId,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
List the consumer group offsets available in the cluster.
|
void |
KafkaAdminClient.listConsumerGroupOffsets(String groupId,
ListConsumerGroupOffsetsOptions options,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
List the consumer group offsets available in the cluster.
|
| Modifier and Type | Method and Description |
|---|---|
OffsetAndMetadata |
OffsetAndMetadata.setMetadata(String metadata)
Set additional metadata for the offset committed
|
OffsetAndMetadata |
OffsetAndMetadata.setOffset(long offset)
Set the offset to commit
|
| Modifier and Type | Method and Description |
|---|---|
Future<Map<TopicPartition,OffsetAndMetadata>> |
KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets)
Commit the specified offsets for the specified list of topics and partitions to Kafka.
|
Future<OffsetAndMetadata> |
KafkaConsumer.committed(TopicPartition topicPartition)
Like
KafkaConsumer.committed(TopicPartition, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
Future<Map<TopicPartition,OffsetAndMetadata>> |
KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets)
Commit the specified offsets for the specified list of topics and partitions to Kafka.
|
void |
KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
Commit the specified offsets for the specified list of topics and partitions to Kafka.
|
void |
KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
Commit the specified offsets for the specified list of topics and partitions to Kafka.
|
void |
KafkaConsumer.committed(TopicPartition topicPartition,
Handler<AsyncResult<OffsetAndMetadata>> handler)
Get the last committed offset for the given partition (whether the commit happened by this process or another).
|
| Constructor and Description |
|---|
OffsetAndMetadata(OffsetAndMetadata that)
Constructor (copy)
|
| Modifier and Type | Method and Description |
|---|---|
Single<OffsetAndMetadata> |
KafkaConsumer.rxCommitted(TopicPartition topicPartition)
Get the last committed offset for the given partition (whether the commit happened by this process or another).
|
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaConsumer.committed(TopicPartition topicPartition,
Handler<AsyncResult<OffsetAndMetadata>> handler)
Get the last committed offset for the given partition (whether the commit happened by this process or another).
|
| Modifier and Type | Method and Description |
|---|---|
Single<OffsetAndMetadata> |
KafkaConsumer.rxCommitted(TopicPartition topicPartition)
Get the last committed offset for the given partition (whether the commit happened by this process or another).
|
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaConsumer.committed(TopicPartition topicPartition,
Handler<AsyncResult<OffsetAndMetadata>> handler)
Get the last committed offset for the given partition (whether the commit happened by this process or another).
|
| Modifier and Type | Method and Description |
|---|---|
Single<OffsetAndMetadata> |
KafkaConsumer.committed(TopicPartition topicPartition)
Get the last committed offset for the given partition (whether the commit happened by this process or another).
|
Single<OffsetAndMetadata> |
KafkaConsumer.rxCommitted(TopicPartition topicPartition)
Get the last committed offset for the given partition (whether the commit happened by this process or another).
|
Copyright © 2023 Eclipse. All rights reserved.