Uses of Class
org.springframework.kafka.test.EmbeddedKafkaZKBroker
Packages that use EmbeddedKafkaZKBroker
-
Uses of EmbeddedKafkaZKBroker in org.springframework.kafka.test
Methods in org.springframework.kafka.test that return EmbeddedKafkaZKBrokerModifier 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.