Package | Description |
---|---|
io.vertx.kafka.admin | |
io.vertx.kafka.client.consumer | |
io.vertx.reactivex.kafka.client.consumer | |
io.vertx.rxjava.kafka.client.consumer |
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).
|
Copyright © 2021 Eclipse. All rights reserved.