Uses of Class
org.springframework.kafka.test.EmbeddedKafkaBroker

Packages that use EmbeddedKafkaBroker

Package	Description
org.springframework.kafka.test
org.springframework.kafka.test.condition	Provides classes for JUnit5 conditions.
org.springframework.kafka.test.rule
org.springframework.kafka.test.utils

Uses of EmbeddedKafkaBroker in org.springframework.kafka.test

Methods in org.springframework.kafka.test that return EmbeddedKafkaBroker

Modifier and Type	Method	Description
EmbeddedKafkaBroker	EmbeddedKafkaBroker.brokerListProperty(String brokerListProperty)	Set the system property with this name to the list of broker addresses.
EmbeddedKafkaBroker	EmbeddedKafkaBroker.brokerProperties(Map<String,String> properties)	Specify the properties to configure Kafka Broker before start, e.g.
EmbeddedKafkaBroker	EmbeddedKafkaBroker.brokerProperty(String property, Object value)	Specify a broker property.
EmbeddedKafkaBroker	EmbeddedKafkaBroker.kafkaPorts(int... ports)	Set explicit ports on which the kafka brokers will listen.
EmbeddedKafkaBroker	EmbeddedKafkaBroker.zkConnectionTimeout(int zkConnectionTimeout)	Set connection timeout for the client to the embedded Zookeeper.
EmbeddedKafkaBroker	EmbeddedKafkaBroker.zkPort(int port)	Set an explicit port for the embedded Zookeeper.
EmbeddedKafkaBroker	EmbeddedKafkaBroker.zkSessionTimeout(int zkSessionTimeout)	Set session timeout for the client to the embedded Zookeeper.

Uses of EmbeddedKafkaBroker in org.springframework.kafka.test.condition

Methods in org.springframework.kafka.test.condition that return EmbeddedKafkaBroker

Modifier and Type	Method	Description
static EmbeddedKafkaBroker	EmbeddedKafkaCondition.getBroker()

Uses of EmbeddedKafkaBroker in org.springframework.kafka.test.rule

Methods in org.springframework.kafka.test.rule that return EmbeddedKafkaBroker

Modifier and Type	Method	Description
EmbeddedKafkaBroker	EmbeddedKafkaRule.getEmbeddedKafka()	Return an underlying delegator EmbeddedKafkaBroker instance.

Uses of EmbeddedKafkaBroker in org.springframework.kafka.test.utils

Methods in org.springframework.kafka.test.utils with parameters of type EmbeddedKafkaBroker

Modifier and Type	Method	Description
static Map<String,Object>	KafkaTestUtils.consumerProps(String group, String autoCommit, EmbeddedKafkaBroker embeddedKafka)	Set up test properties for an <Integer, String> consumer.
static Map<String,Object>	KafkaTestUtils.producerProps(EmbeddedKafkaBroker embeddedKafka)	Set up test properties for an <Integer, String> producer.