Uses of Class
org.springframework.kafka.test.EmbeddedKafkaZKBroker
-
Uses of EmbeddedKafkaZKBroker in org.springframework.kafka.test
Modifier and TypeMethodDescriptionEmbeddedKafkaZKBroker.kafkaPorts
(int... ports) Set explicit ports on which the kafka brokers will listen.EmbeddedKafkaZKBroker.zkConnectionTimeout
(int zkConnectionTimeout) Set connection timeout for the client to the embedded Zookeeper.EmbeddedKafkaZKBroker.zkPort
(int port) Set an explicit port for the embedded Zookeeper.EmbeddedKafkaZKBroker.zkSessionTimeout
(int zkSessionTimeout) Set session timeout for the client to the embedded Zookeeper.