org.apache.kafka.common

Class ConfluentNode

java.lang.Object

org.apache.kafka.common.Node

org.apache.kafka.common.ConfluentNode

public class ConfluentNode
extends Node

Information about a Confluent Server node. Note that ConfluentNode is not consistently used. It is mainly used in conjunction with the Describe Cluster API and internally in the Metadata Cache for the plugins.

Field Summary

Fields inherited from class org.apache.kafka.common.Node

hash, host, id, idString, port, rack

Constructor Summary

Constructors

Constructor and Description
ConfluentNode(int id, String host, int port, String rack, Map<String,String> tags)

Method Summary

Modifier and Type	Method and Description
Map<String,String>	tags() The tags of this node
static Map<String,String>	tags(Node node) Returns the tags if the node is a ConfluentNode or an empty map if not.
String	toString()

Methods inherited from class org.apache.kafka.common.Node

equals, hashCode, hasRack, host, id, idString, isEmpty, noNode, port, rack

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ConfluentNode

public ConfluentNode(int id,
                     String host,
                     int port,
                     String rack,
                     Map<String,String> tags)

Method Detail

tags

public Map<String,String> tags()

The tags of this node

toString

public String toString()

Overrides:

toString in class Node

tags

public static Map<String,String> tags(Node node)

Returns the tags if the node is a ConfluentNode or an empty map if not.