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.