Modifier and Type | Method and Description |
---|---|
static EphemeralKafkaBroker |
EphemeralKafkaBroker.create()
Create a new ephemeral Kafka broker with random broker port and Zookeeper port
|
static EphemeralKafkaBroker |
EphemeralKafkaBroker.create(int kafkaPort)
Create a new ephemeral Kafka broker with the specified broker port and random Zookeeper port
|
static EphemeralKafkaBroker |
EphemeralKafkaBroker.create(int kafkaPort,
int zookeeperPort)
Create a new ephemeral Kafka broker with the specified broker port and Zookeeper port
|
static EphemeralKafkaBroker |
EphemeralKafkaBroker.create(int kafkaPort,
int zookeeperPort,
Properties overrideBrokerProperties)
Create a new ephemeral Kafka broker with the specified broker port, Zookeeper port and config overrides.
|
Modifier and Type | Method and Description |
---|---|
static KafkaHelper |
KafkaHelper.createFor(EphemeralKafkaBroker broker) |
Constructor and Description |
---|
KafkaJunitRule(EphemeralKafkaBroker broker) |
KafkaJunitRule(EphemeralKafkaBroker broker,
com.github.charithe.kafka.KafkaJunitRule.StartupMode mode) |
Copyright © 2017. All rights reserved.