org.springframework.kafka.test

Class EmbeddedKafkaBroker.EmbeddedZookeeper

java.lang.Object

org.springframework.kafka.test.EmbeddedKafkaBroker.EmbeddedZookeeper

Enclosing class:

EmbeddedKafkaBroker

public static final class EmbeddedKafkaBroker.EmbeddedZookeeper
extends java.lang.Object

Ported from scala to allow setting the port.

Since:

2.3

Author:

Gary Russell

Constructor Summary

Constructors

Constructor and Description
EmbeddedZookeeper(int zkPort)

Method Summary

Modifier and Type	Method and Description
java.io.File	getLogDir()
int	getPort()
java.io.File	getSnapshotDir()
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(int zkPort)
                  throws java.io.IOException,
                         java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

Method Detail

getPort

public int getPort()

getSnapshotDir

public java.io.File getSnapshotDir()

getLogDir

public java.io.File getLogDir()

shutdown

public void shutdown()
              throws java.io.IOException

Throws:

java.io.IOException