org.springframework.kafka.test.rule

Interface KafkaRule

All Superinterfaces:

org.junit.rules.TestRule

All Known Implementing Classes:

KafkaEmbedded

public interface KafkaRule
extends org.junit.rules.TestRule

Common functionality for the Kafka JUnit rules

Author:

Marius Bogoevici, Gary Russell

Method Summary

Modifier and Type	Method and Description
BrokerAddress[]	getBrokerAddresses()
java.lang.String	getBrokersAsString()
java.util.List<kafka.server.KafkaServer>	getKafkaServers()
int	getPartitionsPerTopic()
org.I0Itec.zkclient.ZkClient	getZkClient()
java.lang.String	getZookeeperConnectionString()
boolean	isEmbedded()

Methods inherited from interface org.junit.rules.TestRule

apply

Method Detail

getZkClient

org.I0Itec.zkclient.ZkClient getZkClient()

getZookeeperConnectionString

java.lang.String getZookeeperConnectionString()

getBrokerAddresses

BrokerAddress[] getBrokerAddresses()

getBrokersAsString

java.lang.String getBrokersAsString()

isEmbedded

boolean isEmbedded()

getKafkaServers

java.util.List<kafka.server.KafkaServer> getKafkaServers()

getPartitionsPerTopic

int getPartitionsPerTopic()