This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 19cf43635110711c0bafecca68ae355861a0c482 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Jun 22 12:32:47 2026 +0200 Fix #2868: Remove SASL auth from Kafka test pipes The Redpanda testcontainer starts without SASL, but the Kafka pipe definitions used saslAuthType=PLAIN after the kamelet consolidation (f4be62637). This prevented the Kamelet from connecting to Redpanda. Remove saslAuthType/saslUsername/saslPassword from all three Kafka pipes and clean up the corresponding Citrus variables and application.properties. Also increase receive timeouts and add offsetReset=earliest to avoid timing-dependent consumer misses. Co-Authored-By: Claude Opus 4.6 <[email protected]> --- .../src/test/resources/kafka/application.properties | 2 -- .../src/test/resources/kafka/kafka-router-pipe.citrus.it.yaml | 5 +---- .../src/test/resources/kafka/kafka-router-pipe.yaml | 3 --- .../src/test/resources/kafka/kafka-sink-pipe.citrus.it.yaml | 7 +++---- .../src/test/resources/kafka/kafka-sink-pipe.yaml | 3 --- .../src/test/resources/kafka/kafka-source-pipe.citrus.it.yaml | 4 ---- .../src/test/resources/kafka/kafka-source-pipe.yaml | 3 --- 7 files changed, 4 insertions(+), 23 deletions(-) diff --git a/tests/camel-kamelets-itest/src/test/resources/kafka/application.properties b/tests/camel-kamelets-itest/src/test/resources/kafka/application.properties index a879f09e9..4f7aa38d4 100644 --- a/tests/camel-kamelets-itest/src/test/resources/kafka/application.properties +++ b/tests/camel-kamelets-itest/src/test/resources/kafka/application.properties @@ -18,6 +18,4 @@ kafka.topic=${kafka.topic} kafka.bootstrapServers=${CITRUS_TESTCONTAINERS_REDPANDA_BOOTSTRAP_SERVERS} -kafka.saslUsername=${kafka.saslUsername} -kafka.saslPassword=${kafka.saslPassword} kafka.deserializeHeaders=${kafka.deserializeHeaders} diff --git a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.citrus.it.yaml b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.citrus.it.yaml index 82fed4d88..c196bdd12 100644 --- a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.citrus.it.yaml +++ b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.citrus.it.yaml @@ -27,10 +27,6 @@ variables: value: "citrus:unixTimestamp()000" - name: "topic" value: "${kafka.topic}_citrus:currentDate('YYYY-MM-dd')" - - name: "kafka.saslUsername" - value: "redpanda" - - name: "kafka.saslPassword" - value: "admin" actions: # Create Kafka infrastructure - testcontainers: @@ -76,6 +72,7 @@ actions: # Verify Kafka event - receive: endpoint: kafkaRouterConsumer + timeout: 30000 message: body: data: | diff --git a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.yaml b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.yaml index 4dbe0dd6d..766ee5767 100644 --- a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.yaml +++ b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-router-pipe.yaml @@ -55,6 +55,3 @@ spec: properties: bootstrapServers: '{{kafka.bootstrapServers}}' topic: dummy - saslAuthType: 'PLAIN' - saslUsername: '{{kafka.saslUsername}}' - saslPassword: '{{kafka.saslPassword}}' diff --git a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-sink-pipe.citrus.it.yaml b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-sink-pipe.citrus.it.yaml index 3fc20d69f..5c7eaef92 100644 --- a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-sink-pipe.citrus.it.yaml +++ b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-sink-pipe.citrus.it.yaml @@ -25,10 +25,6 @@ variables: value: "citrus:randomNumber(4)" - name: "kafka.message" value: "Camel rocks!" - - name: "kafka.saslUsername" - value: "redpanda" - - name: "kafka.saslPassword" - value: "admin" actions: # Create Kafka infrastructure - testcontainers: @@ -54,10 +50,13 @@ actions: properties: topic: "${kafka.topic}" server: "${CITRUS_TESTCONTAINERS_REDPANDA_BOOTSTRAP_SERVERS}" + consumerGroup: "consumer-1" + offsetReset: "earliest" # Verify Kafka event - receive: endpoint: kafkaSinkConsumer + timeout: 30000 message: body: data: | diff --git a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-sink-pipe.yaml b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-sink-pipe.yaml index 8345cd803..8291e0fbe 100644 --- a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-sink-pipe.yaml +++ b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-sink-pipe.yaml @@ -37,6 +37,3 @@ spec: properties: bootstrapServers: '{{kafka.bootstrapServers}}' topic: '{{kafka.topic}}' - saslAuthType: 'PLAIN' - saslUsername: '{{kafka.saslUsername}}' - saslPassword: '{{kafka.saslPassword}}' diff --git a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.citrus.it.yaml b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.citrus.it.yaml index fa08d0ab8..ae50858bf 100644 --- a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.citrus.it.yaml +++ b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.citrus.it.yaml @@ -27,10 +27,6 @@ variables: value: "citrus:randomNumber(4)" - name: "kafka.message" value: "Camel rocks!" - - name: "kafka.saslUsername" - value: "redpanda" - - name: "kafka.saslPassword" - value: "admin" actions: # Create Kafka infrastructure - testcontainers: diff --git a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.yaml b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.yaml index 57a303758..7ddae5969 100644 --- a/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.yaml +++ b/tests/camel-kamelets-itest/src/test/resources/kafka/kafka-source-pipe.yaml @@ -28,9 +28,6 @@ spec: properties: bootstrapServers: '{{kafka.bootstrapServers}}' topic: '{{kafka.topic}}' - saslAuthType: 'PLAIN' - saslUsername: '{{kafka.saslUsername}}' - saslPassword: '{{kafka.saslPassword}}' deserializeHeaders: '{{kafka.deserializeHeaders}}' sink: uri: "{{http.sink.url}}"
