org.apache.streams.kafka

Class KafkaConfiguration

java.lang.Object

org.apache.streams.kafka.KafkaConfiguration

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class KafkaConfiguration
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Map<String,Object>	getAdditionalProperties()
String	getBrokerlist() A comma-delimited list of broker nodes, used by producer
String	getGroupId() A required field for partitioning distributed consumers
String	getTopic() A topic to read/write from
String	getZkconnect() A comma-delimited list of zookeeper host:ports, used by consumer
int	hashCode()
void	setAdditionalProperty(String name, Object value)
void	setBrokerlist(String brokerlist) A comma-delimited list of broker nodes, used by producer
void	setGroupId(String groupId) A required field for partitioning distributed consumers
void	setTopic(String topic) A topic to read/write from
void	setZkconnect(String zkconnect) A comma-delimited list of zookeeper host:ports, used by consumer
String	toString()
KafkaConfiguration	withAdditionalProperty(String name, Object value)
KafkaConfiguration	withBrokerlist(String brokerlist)
KafkaConfiguration	withGroupId(String groupId)
KafkaConfiguration	withTopic(String topic)
KafkaConfiguration	withZkconnect(String zkconnect)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaConfiguration

public KafkaConfiguration()

Method Detail

getBrokerlist

@BeanProperty(value="brokerlist")
public String getBrokerlist()

A comma-delimited list of broker nodes, used by producer

Returns:

The brokerlist

setBrokerlist

@BeanProperty(value="brokerlist")
public void setBrokerlist(String brokerlist)

A comma-delimited list of broker nodes, used by producer

Parameters:

brokerlist - The brokerlist

withBrokerlist

public KafkaConfiguration withBrokerlist(String brokerlist)

getZkconnect

@BeanProperty(value="zkconnect")
public String getZkconnect()

A comma-delimited list of zookeeper host:ports, used by consumer

Returns:

The zkconnect

setZkconnect

@BeanProperty(value="zkconnect")
public void setZkconnect(String zkconnect)

A comma-delimited list of zookeeper host:ports, used by consumer

Parameters:

zkconnect - The zkconnect

withZkconnect

public KafkaConfiguration withZkconnect(String zkconnect)

getTopic

@BeanProperty(value="topic")
public String getTopic()

A topic to read/write from

Returns:

The topic

setTopic

@BeanProperty(value="topic")
public void setTopic(String topic)

A topic to read/write from

Parameters:

topic - The topic

withTopic

public KafkaConfiguration withTopic(String topic)

getGroupId

@BeanProperty(value="groupId")
public String getGroupId()

A required field for partitioning distributed consumers

Returns:

The groupId

setGroupId

@BeanProperty(value="groupId")
public void setGroupId(String groupId)

A required field for partitioning distributed consumers

Parameters:

groupId - The groupId

withGroupId

public KafkaConfiguration withGroupId(String groupId)

toString

public String toString()

Overrides:

toString in class Object

getAdditionalProperties

@BeanProperty(name="*")
public Map<String,Object> getAdditionalProperties()

setAdditionalProperty

@BeanProperty(name="*")
public void setAdditionalProperty(String name,
                                                          Object value)

withAdditionalProperty

public KafkaConfiguration withAdditionalProperty(String name,
                                                 Object value)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object