public class EmbeddedKafkaRule
extends org.junit.rules.ExternalResource
TestRule wrapper around an EmbeddedKafkaBroker.EmbeddedKafkaBroker| Constructor and Description |
|---|
EmbeddedKafkaRule(int count) |
EmbeddedKafkaRule(int count,
boolean controlledShutdown,
int partitions,
java.lang.String... topics)
Create embedded Kafka brokers listening on random ports.
|
EmbeddedKafkaRule(int count,
boolean controlledShutdown,
java.lang.String... topics)
Create embedded Kafka brokers.
|
| Modifier and Type | Method and Description |
|---|---|
void |
after() |
void |
before() |
EmbeddedKafkaRule |
brokerProperties(java.util.Map<java.lang.String,java.lang.String> brokerProperties)
Specify the properties to configure Kafka Broker before start, e.g.
|
EmbeddedKafkaRule |
brokerProperty(java.lang.String property,
java.lang.Object value)
Specify a broker property.
|
EmbeddedKafkaBroker |
getEmbeddedKafka()
Return an underlying delegator
EmbeddedKafkaBroker instance. |
EmbeddedKafkaRule |
kafkaPorts(int... kafkaPorts)
Set explicit ports on which the kafka brokers will listen.
|
EmbeddedKafkaRule |
zkPort(int port) |
public EmbeddedKafkaRule(int count)
public EmbeddedKafkaRule(int count,
boolean controlledShutdown,
java.lang.String... topics)
count - the number of brokers.controlledShutdown - passed into TestUtils.createBrokerConfig.topics - the topics to create (2 partitions per).public EmbeddedKafkaRule(int count,
boolean controlledShutdown,
int partitions,
java.lang.String... topics)
count - the number of brokers.controlledShutdown - passed into TestUtils.createBrokerConfig.partitions - partitions per topic.topics - the topics to create.public EmbeddedKafkaRule brokerProperties(java.util.Map<java.lang.String,java.lang.String> brokerProperties)
auto.create.topics.enable, transaction.state.log.replication.factor etc.brokerProperties - the properties to use for configuring Kafka Broker(s).KafkaConfigpublic EmbeddedKafkaRule brokerProperty(java.lang.String property, java.lang.Object value)
property - the property name.value - the value.EmbeddedKafkaRule.public EmbeddedKafkaRule kafkaPorts(int... kafkaPorts)
kafkaPorts - the ports.public EmbeddedKafkaRule zkPort(int port)
public EmbeddedKafkaBroker getEmbeddedKafka()
EmbeddedKafkaBroker instance.EmbeddedKafkaBroker instance.public void before()
before in class org.junit.rules.ExternalResourcepublic void after()
after in class org.junit.rules.ExternalResource