From 996af44c7f55b354cdc328d65f99cb5df9bc66b6 Mon Sep 17 00:00:00 2001 From: gmunozfe Date: Thu, 12 Dec 2024 01:07:55 +0100 Subject: [PATCH] Fix advertise-kafka-addr in script command --- .../kie/kogito/testcontainers/KogitoKafkaContainer.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) 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 index 6bd3a3dce7e..72c594d4f8f 100644 --- 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 @@ -53,14 +53,13 @@ public KogitoKafkaContainer() { @Override protected void containerIsStarting(InspectContainerResponse containerInfo, boolean reused) { super.containerIsStarting(containerInfo, reused); - String brokerAdvertisedListener = brokerAdvertisedListener(containerInfo); // Start and configure the advertised address 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 PLAINTEXT://0.0.0.0:29092,OUTSIDE://0.0.0.0:9092 "; - command += format("--advertise-kafka-addr %s ", String.join(",", getBootstrapServers(), brokerAdvertisedListener)); + command += "--advertise-kafka-addr PLAINTEXT://kafka:29092,OUTSIDE://" + getHost() + ":" + getMappedPort(KAFKA_PORT) + " "; command += "--set redpanda.enable_idempotence=true "; command += "--set redpanda.enable_transactions=true "; @@ -73,10 +72,6 @@ public void start() { LOGGER.info("Kafka servers: {}", getBootstrapServers()); } - protected String brokerAdvertisedListener(InspectContainerResponse containerInfo) { - return String.format("PLAINTEXT://%s:29092", containerInfo.getConfig().getHostName()); - } - public String getBootstrapServers() { return format("OUTSIDE://%s:%d", getHost(), getMappedPort(KAFKA_PORT)); }