This is an automated email from the ASF dual-hosted git repository. jmclean pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-plc4x.git
commit ca98538aec2ed2959255cd881852f5cb57e42ed9 Author: Justin Mclean <jmcl...@apache.org> AuthorDate: Tue Feb 20 11:51:04 2018 +1100 simplify --- .../java/org/apache/plc4x/java/examples/kafkabridge/KafkaBridge.java | 4 +--- 1 file changed, 1 insertion(+), 3 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 9466419..509a394 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 @@ -94,9 +94,7 @@ public class KafkaBridge { TStream<Byte> source = top.poll(plcSupplier, config.getPollingInterval(), TimeUnit.MILLISECONDS); // Convert the byte into a string. - TStream<String> stringSource = source.map(value -> { - return Byte.toString(value); - }); + TStream<String> stringSource = source.map(value -> Byte.toString(value)); // Publish the stream to the topic. The String tuple is the message value. kafka.publish(stringSource, config.getKafkaConfig().getTopicName()); -- To stop receiving notification emails like this one, please contact jmcl...@apache.org.