diff --git a/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/base/KafkaBrokerExtension.java b/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/base/KafkaBrokerExtension.java index a9a67d9fcf..fd74ecb91b 100644 --- a/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/base/KafkaBrokerExtension.java +++ b/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/base/KafkaBrokerExtension.java @@ -23,7 +23,7 @@ public class KafkaBrokerExtension implements BeforeAllCallback, ParameterResolver, CloseableResource { public static final Logger LOGGER = Logger.getLogger(KafkaBrokerExtension.class.getName()); - public static final String KAFKA_VERSION = "latest-kafka-2.8.0"; + public static final String KAFKA_VERSION = "latest-kafka-3.0.0"; private static boolean started = false; static StrimziKafkaContainer kafka;