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

Packages that use EmbeddedKafkaBroker

Package	Description
org.springframework.kafka.test	Provides top-level API for EmbeddedKafka.
org.springframework.kafka.test.condition	Provides classes for JUnit5 conditions.
org.springframework.kafka.test.utils	Utils package.

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.

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	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	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	EmbeddedKafkaKraftBroker.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 @Nullable EmbeddedKafkaBroker	EmbeddedKafkaCondition.getBroker()

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)	Deprecated, for removal: This API element is subject to removal in a future version. please, use KafkaTestUtils.consumerProps(EmbeddedKafkaBroker, String, boolean) instead
static Map<String,Object>	KafkaTestUtils.consumerProps(EmbeddedKafkaBroker embeddedKafka, String group, boolean autoCommit)	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.