diff --git a/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java b/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java index 14e9d13b..f8a760d4 100644 --- a/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java +++ b/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java @@ -231,7 +231,7 @@ public class EmbeddedKafkaBroker implements InitializingBean, DisposableBean { /** * Get the port that the embedded Zookeeper is running on or will run on. - * @param zkPort the port. + * @return the port. * @since 2.3 */ public int getZkPort() {