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 |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
Single<List<PartitionInfo>> |
KafkaConsumer.partitionsFor(String topic)
Get metadata about the partitions for a given topic.
|
Single<List<PartitionInfo>> |
KafkaConsumer.rxPartitionsFor(String topic)
Get metadata about the partitions for a given topic.
|
Modifier and Type | Method and Description |
---|---|
Single<List<PartitionInfo>> |
KafkaProducer.partitionsFor(String topic)
Get the partition metadata for the give topic.
|
Single<List<PartitionInfo>> |
KafkaProducer.rxPartitionsFor(String topic)
Get the partition metadata for the give topic.
|
Copyright © 2024 Eclipse. All rights reserved.