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.