Revert "[Fix #3642] Update RedPanda version to latest"

This reverts commit 2ca19d2.
apache · Aug 30, 2024 · ac1325c · ac1325c
1 parent 2ca19d2
commit ac1325c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/kogito-build/kogito-build-no-bom-parent/pom.xml b/kogito-build/kogito-build-no-bom-parent/pom.xml
@@ -72,7 +72,7 @@
     <!-- container images for testing -->
     <container.image.infinispan>infinispan/server:${version.org.infinispan}</container.image.infinispan>
     <container.image.keycloak>quay.io/keycloak/keycloak:${version.org.keycloak}</container.image.keycloak>
-    <container.image.kafka>redpandadata/redpanda:v24.2.3</container.image.kafka>
+    <container.image.kafka>vectorized/redpanda:v21.11.8</container.image.kafka>
     <container.image.wurstmeister.kafka>wurstmeister/kafka:${version.wurstmeister.kafka}</container.image.wurstmeister.kafka>
     <container.image.mongodb>library/mongo:${version.org.mongo-image}</container.image.mongodb>
     <container.image.redis>redislabs/redisearch:${version.org.redis}</container.image.redis>

diff --git a/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java b/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java
@@ -59,7 +59,7 @@ protected void containerIsStarting(InspectContainerResponse containerInfo, boole
         String command = "#!/bin/bash\n";
         command += "/usr/bin/rpk redpanda start --check=false --node-id 0 --smp 1 ";
         command += "--memory 1G --overprovisioned --reserve-memory 0M ";
-        command += "--kafka-addr http://0.0.0.0:29092,http://0.0.0.0:9092 ";
+        command += "--kafka-addr PLAINTEXT://0.0.0.0:29092,OUTSIDE://0.0.0.0:9092 ";
         command += format("--advertise-kafka-addr %s ", String.join(",", getBootstrapServers(), brokerAdvertisedListener));
         command += "--set redpanda.enable_idempotence=true ";
         command += "--set redpanda.enable_transactions=true ";
@@ -74,11 +74,11 @@ public void start() {
     }
 
     protected String brokerAdvertisedListener(InspectContainerResponse containerInfo) {
-        return String.format("http://%s:29092", containerInfo.getConfig().getHostName());
+        return String.format("PLAINTEXT://%s:29092", containerInfo.getConfig().getHostName());
     }
 
     public String getBootstrapServers() {
-        return format("http://%s:%d", getHost(), getMappedPort(KAFKA_PORT));
+        return format("OUTSIDE://%s:%d", getHost(), getMappedPort(KAFKA_PORT));
     }
 
     @Override