org.deeplearning4j.streaming.embedded

Class EmbeddedKafkaCluster

java.lang.Object

org.deeplearning4j.streaming.embedded.EmbeddedKafkaCluster

public class EmbeddedKafkaCluster
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
EmbeddedKafkaCluster(java.lang.String zkConnection)
EmbeddedKafkaCluster(java.lang.String zkConnection, java.util.Properties baseProperties)
EmbeddedKafkaCluster(java.lang.String zkConnection, java.util.Properties baseProperties, java.util.List<java.lang.Integer> ports)

Method Summary

Modifier and Type	Method and Description
void	createTopic(java.lang.String topic, int partitionCount)
void	createTopics(java.lang.String... topics)
java.lang.String	getBrokerList()
java.util.List<java.lang.Integer>	getPorts()
java.util.Properties	getProps()
java.lang.String	getZkConnection()
kafka.utils.ZkUtils	getZkUtils()
void	shutdown()
void	startup()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

EmbeddedKafkaCluster

public EmbeddedKafkaCluster(java.lang.String zkConnection)

EmbeddedKafkaCluster

public EmbeddedKafkaCluster(java.lang.String zkConnection,
                            java.util.Properties baseProperties)

EmbeddedKafkaCluster

public EmbeddedKafkaCluster(java.lang.String zkConnection,
                            java.util.Properties baseProperties,
                            java.util.List<java.lang.Integer> ports)

Method Detail

getZkUtils

public kafka.utils.ZkUtils getZkUtils()

createTopic

public void createTopic(java.lang.String topic,
                        int partitionCount)

createTopics

public void createTopics(java.lang.String... topics)

startup

public void startup()

getProps

public java.util.Properties getProps()

getBrokerList

public java.lang.String getBrokerList()

getPorts

public java.util.List<java.lang.Integer> getPorts()

getZkConnection

public java.lang.String getZkConnection()

shutdown

public void shutdown()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object