diff --git a/context-propagation-quickstart/src/test/java/org/acme/context/prices/KafkaResource.java b/context-propagation-quickstart/src/test/java/org/acme/context/prices/KafkaResource.java
index a59124faaa..a0d1595689 100644
--- a/context-propagation-quickstart/src/test/java/org/acme/context/prices/KafkaResource.java
+++ b/context-propagation-quickstart/src/test/java/org/acme/context/prices/KafkaResource.java
@@ -9,7 +9,7 @@
 
 public class KafkaResource implements QuarkusTestResourceLifecycleManager {
 
-    private final KafkaContainer kafka = new KafkaContainer();
+    private final KafkaContainer kafka = new KafkaContainer("7.7.0");
 
     @Override
     public Map<String, String> start() {
diff --git a/kafka-streams-quickstart/aggregator/src/test/java/org/acme/kafka/streams/aggregator/streams/KafkaResource.java b/kafka-streams-quickstart/aggregator/src/test/java/org/acme/kafka/streams/aggregator/streams/KafkaResource.java
index a54c330d9f..66aaff2da7 100644
--- a/kafka-streams-quickstart/aggregator/src/test/java/org/acme/kafka/streams/aggregator/streams/KafkaResource.java
+++ b/kafka-streams-quickstart/aggregator/src/test/java/org/acme/kafka/streams/aggregator/streams/KafkaResource.java
@@ -9,7 +9,7 @@
 
 public class KafkaResource implements QuarkusTestResourceLifecycleManager {
 
-    private final static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.4.3"));
+    private final static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.0"));
 
     @Override
     public Map<String, String> start() {