diff --git a/kafka-streams/analytics-spring-cloud-streams-kafka-consumer/src/test/java/com/example/analytics/AnalyticsConsumerApplicationTests.java b/kafka-streams/analytics-spring-cloud-streams-kafka-consumer/src/test/java/com/example/analytics/AnalyticsConsumerApplicationTests.java index 01da4a8d..edcbccfc 100644 --- a/kafka-streams/analytics-spring-cloud-streams-kafka-consumer/src/test/java/com/example/analytics/AnalyticsConsumerApplicationTests.java +++ b/kafka-streams/analytics-spring-cloud-streams-kafka-consumer/src/test/java/com/example/analytics/AnalyticsConsumerApplicationTests.java @@ -34,7 +34,7 @@ public class AnalyticsConsumerApplicationTests { private static final DockerImageName KAFKA_TEST_IMAGE = - DockerImageName.parse("confluentinc/cp-kafka:7.3.1"); + DockerImageName.parse("confluentinc/cp-kafka:7.3.3"); @Container public static final KafkaContainer KAFKA_CONTAINER = new KafkaContainer(KAFKA_TEST_IMAGE); diff --git a/kafka-streams/analytics-spring-cloud-streams-kafka-producer/src/test/java/com/example/analytics/AnalyticsProducerApplicationIntegrationTest.java b/kafka-streams/analytics-spring-cloud-streams-kafka-producer/src/test/java/com/example/analytics/AnalyticsProducerApplicationIntegrationTest.java index a21fe5d9..6a3b96e5 100644 --- a/kafka-streams/analytics-spring-cloud-streams-kafka-producer/src/test/java/com/example/analytics/AnalyticsProducerApplicationIntegrationTest.java +++ b/kafka-streams/analytics-spring-cloud-streams-kafka-producer/src/test/java/com/example/analytics/AnalyticsProducerApplicationIntegrationTest.java @@ -39,7 +39,7 @@ class AnalyticsProducerApplicationIntegrationTest { private static final DockerImageName KAFKA_TEST_IMAGE = - DockerImageName.parse("confluentinc/cp-kafka:7.3.1"); + DockerImageName.parse("confluentinc/cp-kafka:7.3.3"); @Container public static final KafkaContainer KAFKA = new KafkaContainer(KAFKA_TEST_IMAGE);