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.

Reply via email to