EmbeddedKafkaRule
@Deprecated
public interface KafkaRule
extends org.junit.rules.TestRule
Modifier and Type | Method and Description |
---|---|
BrokerAddress[] |
getBrokerAddresses()
Deprecated.
|
java.lang.String |
getBrokersAsString()
Deprecated.
|
java.util.List<kafka.server.KafkaServer> |
getKafkaServers()
Deprecated.
|
int |
getPartitionsPerTopic()
Deprecated.
|
org.I0Itec.zkclient.ZkClient |
getZkClient()
Deprecated.
|
java.lang.String |
getZookeeperConnectionString()
Deprecated.
|
boolean |
isEmbedded()
Deprecated.
|
org.I0Itec.zkclient.ZkClient getZkClient()
java.lang.String getZookeeperConnectionString()
BrokerAddress[] getBrokerAddresses()
java.lang.String getBrokersAsString()
boolean isEmbedded()
java.util.List<kafka.server.KafkaServer> getKafkaServers()
int getPartitionsPerTopic()