You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by cd...@apache.org on 2018/03/25 16:17:08 UTC
[incubator-plc4x] 01/03: Moved the kafka initialization to later in
the code
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 <ch...@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
cdutz@apache.org.