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).KafkaConfig
public 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.ExternalResource
public void after()
after
in class org.junit.rules.ExternalResource