[incubator-plc4x] branch master updated: - Made the Kafka example more configurable on the Kafka side.

[cd...@apache.org]

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


The following commit(s) were added to refs/heads/master by this push:
     new 3e8ef09  - Made the Kafka example more configurable on the Kafka side.
3e8ef09 is described below

commit 3e8ef09326cd5c2701966958b6e7411f7ac3e31d
Author: Christofer Dutz <ch...@c-ware.de>
AuthorDate: Wed Mar 14 15:36:46 2018 +0100

    - Made the Kafka example more configurable on the Kafka side.
---
 .../apache/plc4x/java/examples/kafkabridge/KafkaBridge.java   |  3 +++
 .../plc4x/java/examples/kafkabridge/model/KafkaConfig.java    | 11 +++++++++++
 2 files changed, 14 insertions(+)

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 509a394..e299c02 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
@@ -105,6 +105,9 @@ public class KafkaBridge {
     private Map<String,Object> createKafkaConfig() {
         Map<String,Object> kafkaConfig = new HashMap<>();
         kafkaConfig.put("bootstrap.servers", config.getKafkaConfig().getBootstrapServers());
+        if(config.getKafkaConfig().getProperties() != null) {
+            kafkaConfig.putAll(config.getKafkaConfig().getProperties());
+        }
         return kafkaConfig;
     }
 
diff --git a/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/model/KafkaConfig.java b/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/model/KafkaConfig.java
index 99b9099..ff51a13 100644
--- a/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/model/KafkaConfig.java
+++ b/examples/kafka-bridge/src/main/java/org/apache/plc4x/java/examples/kafkabridge/model/KafkaConfig.java
@@ -20,12 +20,16 @@ package org.apache.plc4x.java.examples.kafkabridge.model;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 
+import java.util.Map;
+
 public class KafkaConfig {
 
     @JsonProperty("topic-name")
     private String topicName;
     @JsonProperty("bootstrap-servers")
     private String bootstrapServers;
+    @JsonProperty("properties")
+    private Map<String, String> properties;
 
     public String getTopicName() {
         return topicName;
@@ -43,4 +47,11 @@ public class KafkaConfig {
         this.bootstrapServers = bootstrapServers;
     }
 
+    public Map<String, String> getProperties() {
+        return properties;
+    }
+
+    public void setProperties(Map<String, String> properties) {
+        this.properties = properties;
+    }
 }

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