[camel-quarkus] branch camel-main updated: Fixed kafka because of CAMEL-19827

[jiriondrusek]

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


The following commit(s) were added to refs/heads/camel-main by this push:
     new 4044fc9db0 Fixed kafka because of CAMEL-19827
4044fc9db0 is described below

commit 4044fc9db0614aeb61a9eeed695f73685d740abb
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");
     }