[camel-examples] 02/02: Camel-example-kafka: Fixed build

[acosentino]

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

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-examples.git

commit 429ade0375bb0fc9a7857c65b19918d7fb02851e
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Thu Feb 27 08:47:04 2020 +0100

    Camel-example-kafka: Fixed build
---
 .../org/apache/camel/example/kafka/MessagePublisherClient.java     | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/MessagePublisherClient.java
 
b/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/MessagePublisherClient.java
index 62fcf4e..0aabc64 100644
--- 
a/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/MessagePublisherClient.java
+++ 
b/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/MessagePublisherClient.java
@@ -52,22 +52,21 @@ public final class MessagePublisherClient {
 
                 // setup kafka component with the brokers
                 ComponentsBuilderFactory.kafka()
-                        .brokers("{{kafka.host}}:{{kafka.port}}")
                         .register(camelContext, "kafka");
 
                 from("direct:kafkaStart").routeId("DirectToKafka")
-                    .to("kafka:{{producer.topic}}").log("${headers}");
+                    
.to("kafka:{{producer.topic}}?brokers={{kafka.host}}:{{kafka.port}}").log("${headers}");
 
                 // Topic can be set in header as well.
 
                 from("direct:kafkaStartNoTopic").routeId("kafkaStartNoTopic")
-                    .to("kafka:dummy")
+                    .to("kafka:dummy?brokers={{kafka.host}}:{{kafka.port}}")
                     .log("${headers}");
 
                 // Use custom partitioner based on the key.
 
                 
from("direct:kafkaStartWithPartitioner").routeId("kafkaStartWithPartitioner")
-                        
.to("kafka:{{producer.topic}}?partitioner={{producer.partitioner}}")
+                        
.to("kafka:{{producer.topic}}?partitioner={{producer.partitioner}}&brokers={{kafka.host}}:{{kafka.port}}")
                         .log("${headers}");