Uses of Class
org.springframework.kafka.test.EmbeddedKafkaBroker
Package
Description
Provides classes for JUnit5 conditions.
-
Uses of EmbeddedKafkaBroker in org.springframework.kafka.test
Modifier and TypeMethodDescriptionEmbeddedKafkaBroker.adminTimeout
(int adminTimeout) Set the timeout in seconds for admin operations (e.g.EmbeddedKafkaBroker.brokerListProperty
(String brokerListProperty) Set the system property with this name to the list of broker addresses.EmbeddedKafkaBroker.brokerProperties
(Map<String, String> properties) Specify the properties to configure Kafka Broker before start, e.g.EmbeddedKafkaBroker.brokerProperty
(String property, Object value) Specify a broker property.EmbeddedKafkaBroker.kafkaPorts
(int... ports) Set explicit ports on which the kafka brokers will listen.EmbeddedKafkaBroker.zkConnectionTimeout
(int zkConnectionTimeout) Set connection timeout for the client to the embedded Zookeeper.EmbeddedKafkaBroker.zkPort
(int port) Set an explicit port for the embedded Zookeeper.EmbeddedKafkaBroker.zkSessionTimeout
(int zkSessionTimeout) Set session timeout for the client to the embedded Zookeeper. -
Uses of EmbeddedKafkaBroker in org.springframework.kafka.test.condition
-
Uses of EmbeddedKafkaBroker in org.springframework.kafka.test.rule
Modifier and TypeMethodDescriptionEmbeddedKafkaRule.getEmbeddedKafka()
Return an underlying delegatorEmbeddedKafkaBroker
instance. -
Uses of EmbeddedKafkaBroker in org.springframework.kafka.test.utils
Modifier and TypeMethodDescriptionKafkaTestUtils.consumerProps
(String group, String autoCommit, EmbeddedKafkaBroker embeddedKafka) Set up test properties for an<Integer, String>
consumer.KafkaTestUtils.producerProps
(EmbeddedKafkaBroker embeddedKafka) Set up test properties for an<Integer, String>
producer.