[incubator-plc4x] 01/03: Moved the kafka initialization to later in the code

[cdutz]

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

cdutz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-plc4x.git

commit d1578cc0453cfd5c33acc2d473933f99ac4aa19b
Author: Christofer Dutz <christofer.d...@c-ware.de>
AuthorDate: Sun Mar 25 18:14:39 2018 +0200

    Moved the kafka initialization to later in the code
---
 .../org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java   | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git 
a/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java
 
b/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java
index e299c02..0a223ce 100644
--- 
a/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java
+++ 
b/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java
@@ -71,12 +71,7 @@ public class KafkaBridge {
         DirectProvider dp = new DirectProvider();
         Topology top = dp.newTopology("kafka-bridge");
 
-        // Create the Kafka Producer broker connector
-        Map<String,Object> kafkaConfig = createKafkaConfig();
-        KafkaProducer kafka = new KafkaProducer(top, () -> kafkaConfig);
-
         Map<String, ReadRequestItem> readRequestItems = new HashMap<>();
-
         for(Address address : config.getPlcConfig().getAddresses()) {
             try {
                 org.apache.plc4x.java.api.model.Address plcAddress = 
plcAdapter.parseAddress(address.getAddress());
@@ -97,6 +92,9 @@ public class KafkaBridge {
         TStream<String> stringSource = source.map(value -> 
Byte.toString(value));
 
         // Publish the stream to the topic.  The String tuple is the message 
value.
+        // Create the Kafka Producer broker connector
+        Map<String,Object> kafkaConfig = createKafkaConfig();
+        KafkaProducer kafka = new KafkaProducer(top, () -> kafkaConfig);
         kafka.publish(stringSource, config.getKafkaConfig().getTopicName());
 
         dp.submit(top);

-- 
To stop receiving notification emails like this one, please contact
cd...@apache.org.