From d3e0a45ee624ca3447ed7fe212e532911860f876 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Micha=C5=82?= Date: Fri, 15 Dec 2023 13:49:47 +0100 Subject: [PATCH] GH-2927 Test that zk broker can be resolved --- .../kafka/test/condition/EmbeddedKafkaConditionTests.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/spring-kafka-test/src/test/java/org/springframework/kafka/test/condition/EmbeddedKafkaConditionTests.java b/spring-kafka-test/src/test/java/org/springframework/kafka/test/condition/EmbeddedKafkaConditionTests.java index 27b5a93a8f..10452ce2f6 100644 --- a/spring-kafka-test/src/test/java/org/springframework/kafka/test/condition/EmbeddedKafkaConditionTests.java +++ b/spring-kafka-test/src/test/java/org/springframework/kafka/test/condition/EmbeddedKafkaConditionTests.java @@ -21,6 +21,7 @@ import org.junit.jupiter.api.Test; import org.springframework.kafka.test.EmbeddedKafkaBroker; +import org.springframework.kafka.test.EmbeddedKafkaZKBroker; import org.springframework.kafka.test.context.EmbeddedKafka; import org.springframework.kafka.test.utils.KafkaTestUtils; @@ -41,4 +42,9 @@ public void test(EmbeddedKafkaBroker broker) { assertThat(broker.getPartitionsPerTopic()).isEqualTo(3); } + @Test + public void testResolver(EmbeddedKafkaZKBroker broker) { + assertThat(broker).isNotNull(); + } + }