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,
Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
Constructor
|
ConsumerGroupDescription(String groupId,
boolean isSimpleConsumerGroup,
List<MemberDescription> members,
String partitionAssignor,
org.apache.kafka.common.ConsumerGroupState state,
Node coordinator,
Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
Constructor
|
Constructor and Description |
---|
ClusterDescription(String clusterId,
Node controller,
List<Node> nodes,
Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
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 © 2024 Eclipse. All rights reserved.