Package 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 Object

Ported from scala to allow setting the port.

Since:

2.3

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
EmbeddedZookeeper(int zkPort)

Method Summary

Modifier and Type	Method	Description
File	getLogDir()
int	getPort()
File	getSnapshotDir()
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Details

EmbeddedZookeeper

public EmbeddedZookeeper(int zkPort)
                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

Method Details

getPort

public int getPort()

getSnapshotDir

public File getSnapshotDir()

getLogDir

public File getLogDir()

shutdown

public void shutdown()
              throws IOException

Throws:

IOException