org.springframework.integration.kafka.core
Class BrokerAddress

java.lang.Object
  extended by org.springframework.integration.kafka.core.BrokerAddress

public class BrokerAddress
extends java.lang.Object

Encapsulates the address of a Kafka broker.


Field Summary
static int DEFAULT_PORT
           
 
Constructor Summary
BrokerAddress(kafka.cluster.Broker broker)
           
BrokerAddress(java.lang.String host)
           
BrokerAddress(java.lang.String host, int port)
           
 
Method Summary
 boolean equals(java.lang.Object o)
           
static BrokerAddress fromAddress(java.lang.String address)
           
 java.lang.String getHost()
           
 int getPort()
           
 int hashCode()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Field Detail

DEFAULT_PORT

public static final int DEFAULT_PORT
See Also:
Constant Field Values
Constructor Detail

BrokerAddress

public BrokerAddress(java.lang.String host,
                     int port)

BrokerAddress

public BrokerAddress(java.lang.String host)

BrokerAddress

public BrokerAddress(kafka.cluster.Broker broker)
Method Detail

fromAddress

public static BrokerAddress fromAddress(java.lang.String address)

getHost

public java.lang.String getHost()

getPort

public int getPort()

hashCode

public int hashCode()
Overrides:
hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object o)
Overrides:
equals in class java.lang.Object

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object