From b2f646a1f5505f463bcbf71efc0e1833da2fed8e Mon Sep 17 00:00:00 2001 From: Raja Kolli Date: Sun, 23 Apr 2023 11:26:48 +0530 Subject: [PATCH] sync with kafka version --- .../example/analytics/AnalyticsConsumerApplicationTests.java | 2 +- .../analytics/AnalyticsProducerApplicationIntegrationTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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);