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/30 08:36:21 UTC
(camel-quarkus) 06/09: 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
commit 7e8091c215670c6641aac790cc8afc29b3a594e1
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");
}