org.apache.spark.streaming.kafka

Class Broker

Object

org.apache.spark.streaming.kafka.Broker

All Implemented Interfaces:

java.io.Serializable

public final class Broker
extends Object
implements scala.Serializable

Represents the host and port info for a Kafka broker. Differs from the Kafka project's internal kafka.cluster.Broker, which contains a server ID.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
static Broker	apply(String host, int port)
static Broker	create(String host, int port)
boolean	equals(Object obj) Broker's port
int	hashCode()
String	host() Broker's hostname
int	port() Broker's port
String	toString()
static scala.Option<scala.Tuple2<String,Object>>	unapply(Broker broker)

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

Method Detail

create

public static Broker create(String host,
                            int port)

apply

public static Broker apply(String host,
                           int port)

unapply

public static scala.Option<scala.Tuple2<String,Object>> unapply(Broker broker)

host

public String host()

Broker's hostname

port

public int port()

Broker's port

equals

public boolean equals(Object obj)

Broker's port

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object