Modifier and Type | Method and Description |
---|---|
PartitionInfo |
PartitionInfo.setInSyncReplicas(List<Node> inSyncReplicas)
Set the subset of the replicas that are in sync
|
PartitionInfo |
PartitionInfo.setLeader(Node leader)
Set the node id of the node currently acting as a leader
|
PartitionInfo |
PartitionInfo.setPartition(int partition)
Set the partition id
|
PartitionInfo |
PartitionInfo.setReplicas(List<Node> replicas)
Set the complete set of replicas for this partition
|
PartitionInfo |
PartitionInfo.setTopic(String topic)
Set the topic name
|
Modifier and Type | Method and Description |
---|---|
static void |
PartitionInfoConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
PartitionInfo obj) |
static void |
PartitionInfoConverter.toJson(PartitionInfo obj,
JsonObject json) |
static void |
PartitionInfoConverter.toJson(PartitionInfo obj,
Map<String,Object> json) |
Modifier and Type | Method and Description |
---|---|
Future<Map<String,List<PartitionInfo>>> |
KafkaConsumer.listTopics()
Like
KafkaConsumer.listTopics(Handler) but returns a Future of the asynchronous result |
Future<List<PartitionInfo>> |
KafkaConsumer.partitionsFor(String topic)
Like
KafkaConsumer.partitionsFor(String, Handler) but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
KafkaConsumer<K,V> |
KafkaConsumer.listTopics(Handler<AsyncResult<Map<String,List<PartitionInfo>>>> handler)
Get metadata about partitions for all topics that the user is authorized to view.
|
KafkaConsumer<K,V> |
KafkaConsumer.partitionsFor(String topic,
Handler<AsyncResult<List<PartitionInfo>>> handler)
Get metadata about the partitions for a given topic.
|
Modifier and Type | Method and Description |
---|---|
Future<List<PartitionInfo>> |
KafkaProducer.partitionsFor(String topic)
Like
KafkaProducer.partitionsFor(String, Handler) but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
KafkaProducer<K,V> |
KafkaProducer.partitionsFor(String topic,
Handler<AsyncResult<List<PartitionInfo>>> handler)
Get the partition metadata for the give topic.
|
Modifier and Type | Method and Description |
---|---|
Single<List<PartitionInfo>> |
KafkaConsumer.rxPartitionsFor(String topic)
Get metadata about the partitions for a given topic.
|
Modifier and Type | Method and Description |
---|---|
KafkaConsumer<K,V> |
KafkaConsumer.partitionsFor(String topic,
Handler<AsyncResult<List<PartitionInfo>>> handler)
Get metadata about the partitions for a given topic.
|
Modifier and Type | Method and Description |
---|---|
Single<List<PartitionInfo>> |
KafkaProducer.rxPartitionsFor(String topic)
Get the partition metadata for the give topic.
|
Modifier and Type | Method and Description |
---|---|
KafkaProducer<K,V> |
KafkaProducer.partitionsFor(String topic,
Handler<AsyncResult<List<PartitionInfo>>> handler)
Get the partition metadata for the give topic.
|
Modifier and Type | Method and Description |
---|---|
Single<List<PartitionInfo>> |
KafkaConsumer.rxPartitionsFor(String topic)
Get metadata about the partitions for a given topic.
|
Modifier and Type | Method and Description |
---|---|
KafkaConsumer<K,V> |
KafkaConsumer.partitionsFor(String topic,
Handler<AsyncResult<List<PartitionInfo>>> handler)
Get metadata about the partitions for a given topic.
|
Modifier and Type | Method and Description |
---|---|
Single<List<PartitionInfo>> |
KafkaProducer.rxPartitionsFor(String topic)
Get the partition metadata for the give topic.
|
Modifier and Type | Method and Description |
---|---|
KafkaProducer<K,V> |
KafkaProducer.partitionsFor(String topic,
Handler<AsyncResult<List<PartitionInfo>>> handler)
Get the partition metadata for the give topic.
|
Copyright © 2021 Eclipse. All rights reserved.