public class JUnitKafkaServer
extends org.junit.rules.ExternalResource
Constructor and Description |
---|
JUnitKafkaServer() |
JUnitKafkaServer(String kafkaLogDir) |
JUnitKafkaServer(org.junit.rules.TemporaryFolder temporaryFolder) |
Modifier and Type | Method and Description |
---|---|
void |
after() |
void |
before() |
String |
getKafkaConnectString() |
String |
getZookeeperConnectString() |
public JUnitKafkaServer()
public JUnitKafkaServer(String kafkaLogDir)
public JUnitKafkaServer(org.junit.rules.TemporaryFolder temporaryFolder)
public void before() throws Exception
before
in class org.junit.rules.ExternalResource
Exception
public void after()
after
in class org.junit.rules.ExternalResource
public String getKafkaConnectString()
public String getZookeeperConnectString()
Copyright © 2018. All rights reserved.