| Package | Description | 
|---|---|
| io.vertx.kafka.admin | |
| io.vertx.kafka.client.common | 
| Modifier and Type | Method and Description | 
|---|---|
Node | 
ClusterDescription.getController()  | 
Node | 
ConsumerGroupDescription.getCoordinator()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<Node> | 
ClusterDescription.getNodes()  | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterDescription | 
ClusterDescription.addNode(Node node)
Add a node belonging to this cluster to the current node list. 
 | 
ClusterDescription | 
ClusterDescription.setController(Node controller)
Set the controller node. 
 | 
ConsumerGroupDescription | 
ConsumerGroupDescription.setCoordinator(Node coordinator)
Set the consumer group coordinator, or null if the coordinator is not known 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ClusterDescription | 
ClusterDescription.setNodes(List<Node> nodes)
Set the nodes belonging to this cluster 
 | 
| Constructor and Description | 
|---|
ClusterDescription(String clusterId,
                  Node controller,
                  List<Node> nodes)
Constructor 
 | 
ConsumerGroupDescription(String groupId,
                        boolean isSimpleConsumerGroup,
                        List<MemberDescription> members,
                        String partitionAssignor,
                        org.apache.kafka.common.ConsumerGroupState state,
                        Node coordinator)
Constructor 
 | 
| Constructor and Description | 
|---|
ClusterDescription(String clusterId,
                  Node controller,
                  List<Node> nodes)
Constructor 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Node | 
PartitionInfo.getLeader()  | 
Node | 
TopicPartitionInfo.getLeader()  | 
Node | 
Node.setHasRack(boolean hasRack)
Set if this node has a defined rack 
 | 
Node | 
Node.setHost(String host)
Set the host name for this node 
 | 
Node | 
Node.setId(int id)
Set the node id of this node 
 | 
Node | 
Node.setIdString(String idString)
Set the string representation of the node id 
 | 
Node | 
Node.setIsEmpty(boolean isEmpty)
Set if this node is empty 
 | 
Node | 
Node.setPort(int port)
Set the port for this node 
 | 
Node | 
Node.setRack(String rack)
Set the rack for this node 
 | 
| Modifier and Type | Method and Description | 
|---|---|
List<Node> | 
PartitionInfo.getInSyncReplicas()  | 
List<Node> | 
TopicPartitionInfo.getIsr()  | 
List<Node> | 
PartitionInfo.getReplicas()  | 
List<Node> | 
TopicPartitionInfo.getReplicas()  | 
| Modifier and Type | Method and Description | 
|---|---|
PartitionInfo | 
PartitionInfo.setLeader(Node leader)
Set the node id of the node currently acting as a leader 
 | 
TopicPartitionInfo | 
TopicPartitionInfo.setLeader(Node leader)
Set the node id of the node currently acting as a leader 
 | 
| Modifier and Type | Method and Description | 
|---|---|
PartitionInfo | 
PartitionInfo.setInSyncReplicas(List<Node> inSyncReplicas)
Set the subset of the replicas that are in sync 
 | 
TopicPartitionInfo | 
TopicPartitionInfo.setIsr(List<Node> isr)
Set the subset of the replicas that are in sync 
 | 
PartitionInfo | 
PartitionInfo.setReplicas(List<Node> replicas)
Set the complete set of replicas for this partition 
 | 
TopicPartitionInfo | 
TopicPartitionInfo.setReplicas(List<Node> replicas)
Set the complete set of replicas for this partition 
 | 
| Constructor and Description | 
|---|
PartitionInfo(List<Node> inSyncReplicas,
             Node leader,
             int partition,
             List<Node> replicas,
             String topic)
Constructor 
 | 
TopicPartitionInfo(List<Node> isr,
                  Node leader,
                  int partition,
                  List<Node> replicas)
Constructor 
 | 
| Constructor and Description | 
|---|
PartitionInfo(List<Node> inSyncReplicas,
             Node leader,
             int partition,
             List<Node> replicas,
             String topic)
Constructor 
 | 
PartitionInfo(List<Node> inSyncReplicas,
             Node leader,
             int partition,
             List<Node> replicas,
             String topic)
Constructor 
 | 
TopicPartitionInfo(List<Node> isr,
                  Node leader,
                  int partition,
                  List<Node> replicas)
Constructor 
 | 
TopicPartitionInfo(List<Node> isr,
                  Node leader,
                  int partition,
                  List<Node> replicas)
Constructor 
 | 
Copyright © 2023 Eclipse. All rights reserved.