This is an automated email from the ASF dual-hosted git repository.
hutcheb pushed a commit to branch feature/plc4go
in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit b29a8d7cf54991e51489e33af7f79576d4c6244f
Merge: 797908c 824c791
Author: hutcheb <ben.hut...@gmail.com>
AuthorDate: Mon Nov 23 07:13:39 2020 -0500
Merge pull request #202 from apache/feature/kafkasink
Feature/kafkasink - Add a kafka sink
.../java/simulated/connection/SimulatedDevice.java | 17 +-
plc4j/integrations/apache-kafka/README.md | 233 ++++++++++++++----
.../apache-kafka/config/plc4x-sink.properties | 77 ++++++
.../apache-kafka/config/plc4x-source.properties | 76 ++++--
plc4j/integrations/apache-kafka/pom.xml | 86 ++++++-
.../org/apache/plc4x/kafka/Plc4xSinkConnector.java | 123 ++++++++++
.../java/org/apache/plc4x/kafka/Plc4xSinkTask.java | 271 +++++++++++++++++++++
.../apache/plc4x/kafka/Plc4xSourceConnector.java | 210 +++-------------
.../org/apache/plc4x/kafka/Plc4xSourceTask.java | 141 ++++++-----
.../org/apache/plc4x/kafka/config/Constants.java | 89 +++++++
.../org/apache/plc4x/kafka/config/Defaults.java | 33 ---
.../java/org/apache/plc4x/kafka/config/Field.java | 65 +++++
.../java/org/apache/plc4x/kafka/config/Job.java | 62 ++++-
.../apache/plc4x/kafka/config/JobReference.java | 34 ++-
.../java/org/apache/plc4x/kafka/config/Sink.java | 135 ++++++++++
.../org/apache/plc4x/kafka/config/SinkConfig.java | 84 +++++++
.../java/org/apache/plc4x/kafka/config/Source.java | 101 +++++++-
.../apache/plc4x/kafka/config/SourceConfig.java | 129 +++++-----
.../kafka/exceptions/ConfigurationException.java | 31 ---
.../apache/plc4x/kafka/config/SinkConfigTest.java | 131 ++++++++++
.../apache/plc4x/kafka/config/SinkTaskTest.java | 149 +++++++++++
.../plc4x/kafka/config/SourceConfigTest.java | 155 +++++++++++-
.../apache/plc4x/kafka/config/SourceTaskTest.java | 105 ++++++++
.../kafka/properties/sink_task_no_error.properties | 62 +++++
.../properties/source_task_no_error.properties | 62 +++++
pom.xml | 4 +
.../resources/protocols/simulated/simulated.mspec | 1 -
sandbox/opcua-server/pom.xml | 36 ++-
.../asciidoc/users/integrations/apache-kafka.adoc | 218 ++++++++++++++++-
29 files changed, 2448 insertions(+), 472 deletions(-)
