Add test for Confluent platform version 7 to KafkaContainerTest (#5989)

edysli · web-flow · commit e013a65eb543 · 2022-11-14T17:59:26.000+01:00
diff --git a/modules/kafka/src/test/java/org/testcontainers/containers/KafkaContainerTest.java b/modules/kafka/src/test/java/org/testcontainers/containers/KafkaContainerTest.java
@@ -96,6 +96,14 @@ public void testExternalZookeeperWithExternalNetwork() throws Exception {
         }
     }
 
+    @Test
+    public void testConfluentPlatformVersion7() throws Exception {
+        try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.2.2"))) {
+            kafka.start();
+            testKafkaFunctionality(kafka.getBootstrapServers());
+        }
+    }
+
     @Test
     public void testConfluentPlatformVersion5() throws Exception {
         try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.4.3"))) {

Original file line number	Diff line number	Diff line change
`@@ -96,6 +96,14 @@ public void testExternalZookeeperWithExternalNetwork() throws Exception {`
`96`	`96`	`}`
`97`	`97`	`}`
`98`	`98`
	`99`	`+ @Test`
	`100`	`+ public void testConfluentPlatformVersion7() throws Exception {`
	`101`	`+ try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.2.2"))) {`
	`102`	`+ kafka.start();`
	`103`	`+ testKafkaFunctionality(kafka.getBootstrapServers());`
	`104`	`+ }`
	`105`	`+ }`
	`106`	`+`
`99`	`107`	`@Test`
`100`	`108`	`public void testConfluentPlatformVersion5() throws Exception {`
`101`	`109`	`try (KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.4.3"))) {`