[#noissue] Update kafka docker images

pinpoint-apm · Sep 24, 2024 · 05006bb · 05006bb
1 parent 3ba381a
commit 05006bb
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...-testweb/kafka-plugin-testweb/src/test/java/com/pinpoint/test/plugin/kafka/KafkaTest.java b/...-testweb/kafka-plugin-testweb/src/test/java/com/pinpoint/test/plugin/kafka/KafkaTest.java
@@ -15,7 +15,7 @@ public class KafkaTest {
     public static void beforeClass() {
         Assume.assumeTrue("Docker not enabled", DockerClientFactory.instance().isDockerAvailable());
 
-        container = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1"));
+        container = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.1"));
 
         container.start();
         final String bootstrapServers = container.getBootstrapServers();

diff --git a/...ins-it/kafka-it/kafka-3-it/src/test/java/test/pinpoint/plugin/kafka/Kafka3UnitServer.java b/...ins-it/kafka-it/kafka-3-it/src/test/java/test/pinpoint/plugin/kafka/Kafka3UnitServer.java
@@ -41,7 +41,7 @@ public class Kafka3UnitServer implements SharedTestLifeCycle {
     @Override
     public Properties beforeAll() {
         Assume.assumeTrue("Docker not enabled", DockerClientFactory.instance().isDockerAvailable());
-        container = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1"));
+        container = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.1"));
 
         container.start();
         int port = container.getFirstMappedPort();

diff --git a/.../kafka-it/kafka-3-it/src/test/java/test/pinpoint/plugin/kafka/KafkaStreamsUnitServer.java b/.../kafka-it/kafka-3-it/src/test/java/test/pinpoint/plugin/kafka/KafkaStreamsUnitServer.java
@@ -46,7 +46,7 @@ public class KafkaStreamsUnitServer implements SharedTestLifeCycle {
     @Override
     public Properties beforeAll() {
         Assume.assumeTrue("Docker not enabled", DockerClientFactory.instance().isDockerAvailable());
-        container = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.1"));
+        container = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.1"));
 
         container.start();
         int port = container.getFirstMappedPort();