You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@plc4x.apache.org by hu...@apache.org on 2020/11/22 10:50:11 UTC

[plc4x] branch feature/kafkasink updated (1aa3c6f -> c21b1c2)

This is an automated email from the ASF dual-hosted git repository.

hutcheb pushed a change to branch feature/kafkasink
in repository https://gitbox.apache.org/repos/asf/plc4x.git.


    from 1aa3c6f  Set each Plc field to optional
     add c21b1c2  Updated Fields Struct in Schema.

No new revisions were added by this update.

Summary of changes:
 .../apache-kafka/config/plc4x-sink.properties      | 36 ++++++------
 .../apache-kafka/config/plc4x-source.properties    | 24 ++++----
 .../java/org/apache/plc4x/kafka/Plc4xSinkTask.java | 68 ++++++++++++++--------
 .../org/apache/plc4x/kafka/Plc4xSourceTask.java    | 29 ++++++---
 .../org/apache/plc4x/kafka/config/Constants.java   |  4 ++
 .../apache/plc4x/kafka/config/SinkTaskTest.java    | 41 ++++++-------
 6 files changed, 119 insertions(+), 83 deletions(-)