This is an automated email from the ASF dual-hosted git repository.

jiriondrusek pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git

commit 36a981c418d7de6c487a13c254b19d8e8659fafc
Author: JiriOndrusek <ondrusek.j...@gmail.com>
AuthorDate: Fri Oct 20 13:05:20 2023 +0200

    Fixed kafka because of CAMEL-19827
---
 .../main/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslRoutes.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/integration-tests/kafka-sasl/src/main/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslRoutes.java
 
b/integration-tests/kafka-sasl/src/main/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslRoutes.java
index a6f0f7326b..4a1df61c0a 100644
--- 
a/integration-tests/kafka-sasl/src/main/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslRoutes.java
+++ 
b/integration-tests/kafka-sasl/src/main/java/org/apache/camel/quarkus/kafka/sasl/KafkaSaslRoutes.java
@@ -23,7 +23,7 @@ public class KafkaSaslRoutes extends RouteBuilder {
     public void configure() throws Exception {
         // Note: kafka component configuration is done via 
quarkus-kubernetes-service-binding.
         // See configuration in src/test/resources/k8s-sb/kafka
-        from("kafka:inbound?autoOffsetReset=earliest")
+        
from("kafka:inbound?autoOffsetReset=earliest&preValidateHostAndPort=false")
                 .to("log:kafka")
                 .to("kafka:outbound");
     }

Reply via email to