You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ji...@apache.org on 2023/10/20 11:05:48 UTC
[camel-quarkus] branch camel-main updated: Fixed kafka because of CAMEL-19827
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 <on...@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");
}