| 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 | 
|---|---|
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 | 
|---|---|
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 © 2020 Eclipse. All rights reserved.