From e89ab191bc5bb8c1eb054c20f811881e0ec6b663 Mon Sep 17 00:00:00 2001 From: sligara7 Date: Fri, 7 Aug 2026 13:05:58 -0400 Subject: [PATCH 1/2] repro: parametrize kafka advertised listener with KAFKA_PORT The advertised listener was hardcoded to localhost:9092, so a KAFKA_PORT override let clients bootstrap on the custom port but then redirected them to 9092 for produce connections. Found running the stack on a host where 9092 was already taken. --- integration/queueserver-repro/reproduce.sh | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/integration/queueserver-repro/reproduce.sh b/integration/queueserver-repro/reproduce.sh index b72304d6..82e1b5d0 100755 --- a/integration/queueserver-repro/reproduce.sh +++ b/integration/queueserver-repro/reproduce.sh @@ -499,7 +499,7 @@ start_infra() { -e KAFKA_NODE_ID=1 \ -e KAFKA_PROCESS_ROLES=broker,controller \ -e KAFKA_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093 \ - -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 \ + -e KAFKA_ADVERTISED_LISTENERS="PLAINTEXT://localhost:${KAFKA_PORT}" \ -e KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER \ -e KAFKA_CONTROLLER_QUORUM_VOTERS=1@localhost:9093 \ -e KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT \ From 7e80c7bdf407525549138f19b10ed882d2e0f878 Mon Sep 17 00:00:00 2001 From: sligara7 Date: Fri, 7 Aug 2026 14:43:32 -0400 Subject: [PATCH 2/2] repro: don't publish kafka's KRaft controller port to the host Nothing outside the container uses 9093 (the quorum voter address is container-local), but the hardcoded host binding made 'up' fail on any host where 9093 was already taken. --- integration/queueserver-repro/reproduce.sh | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/integration/queueserver-repro/reproduce.sh b/integration/queueserver-repro/reproduce.sh index 82e1b5d0..4fd29fd2 100755 --- a/integration/queueserver-repro/reproduce.sh +++ b/integration/queueserver-repro/reproduce.sh @@ -495,7 +495,7 @@ start_infra() { # Single-node KRaft, as the NSLS-II profile-testing CI uses. if [ "$WITH_KAFKA" = "1" ]; then start_container "$CT_KAFKA" \ - -p "${KAFKA_PORT}:9092" -p 9093:9093 \ + -p "${KAFKA_PORT}:9092" \ -e KAFKA_NODE_ID=1 \ -e KAFKA_PROCESS_ROLES=broker,controller \ -e KAFKA_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093 \