Uses of Interface
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

Classes in org.springframework.kafka.test that implement EmbeddedKafkaBroker

Modifier and Type	Class	Description
class	EmbeddedKafkaKraftBroker	An embedded Kafka Broker(s) using KRaft.
class	EmbeddedKafkaZKBroker	An embedded Kafka Broker(s) and Zookeeper manager.

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

Modifier and Type	Method	Description
EmbeddedKafkaBroker	EmbeddedKafkaBroker.adminTimeout(int adminTimeout)	Set the timeout in seconds for admin operations (e.g.
EmbeddedKafkaBroker	EmbeddedKafkaKraftBroker.adminTimeout(int adminTimeout)
EmbeddedKafkaBroker	EmbeddedKafkaZKBroker.adminTimeout(int adminTimeout)
EmbeddedKafkaBroker	EmbeddedKafkaBroker.brokerListProperty(String brokerListProperty)	Set the system property with this name to the list of broker addresses.
EmbeddedKafkaBroker	EmbeddedKafkaKraftBroker.brokerListProperty(String brokerListProperty)	Set the system property with this name to the list of broker addresses.
EmbeddedKafkaBroker	EmbeddedKafkaZKBroker.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	EmbeddedKafkaKraftBroker.brokerProperties(Map<String,String> properties)	Specify the properties to configure Kafka Broker before start, e.g.
EmbeddedKafkaBroker	EmbeddedKafkaZKBroker.brokerProperties(Map<String,String> properties)	Specify the properties to configure Kafka Broker before start, e.g.
EmbeddedKafkaBroker	EmbeddedKafkaKraftBroker.brokerProperty(String property, Object value)	Specify a broker property.
EmbeddedKafkaBroker	EmbeddedKafkaZKBroker.brokerProperty(String property, Object value)	Specify a broker property.
static EmbeddedKafkaBroker	EmbeddedKafkaBrokerFactory.create(EmbeddedKafka embeddedKafka)	Create an EmbeddedKafkaBroker based on the EmbeddedKafka annotation.
static EmbeddedKafkaBroker	EmbeddedKafkaBrokerFactory.create(EmbeddedKafka embeddedKafka, Function<String,String> propertyResolver)	Create an EmbeddedKafkaBroker based on the EmbeddedKafka annotation.
EmbeddedKafkaBroker	EmbeddedKafkaBroker.kafkaPorts(int... ports)	Set explicit ports on which the kafka brokers will listen.

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.