org.springframework.xd.test.kafka

Class EmbeddedZookeeper

java.lang.Object

org.springframework.xd.test.kafka.EmbeddedZookeeper

public class EmbeddedZookeeper
extends java.lang.Object

A port of kafka.zk.EmbeddedZookeeper, compatible with Zookeeper 3.4 API

Author:

Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
EmbeddedZookeeper(java.lang.String connectString)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getConnectString()
java.io.File	getLogDir()
int	getPort()
java.io.File	getSnapshotDir()
int	getTickTime()
org.apache.zookeeper.server.ZooKeeperServer	getZookeeper()
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

EmbeddedZookeeper

public EmbeddedZookeeper(java.lang.String connectString)
                  throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

getConnectString

public java.lang.String getConnectString()

getSnapshotDir

public java.io.File getSnapshotDir()

getLogDir

public java.io.File getLogDir()

getTickTime

public int getTickTime()

getZookeeper

public org.apache.zookeeper.server.ZooKeeperServer getZookeeper()

getPort

public int getPort()

shutdown

public void shutdown()