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/23 12:15:41 UTC
[plc4x] branch feature/plc4go updated (797908c -> b29a8d7)
This is an automated email from the ASF dual-hosted git repository.
hutcheb pushed a change to branch feature/plc4go
in repository https://gitbox.apache.org/repos/asf/plc4x.git.
from 797908c - Fine tuned the code generation a bit to allow accessing some additional information
add c73a889 Wrote first value from Kafka
add 4dc7a5a Removed request connectionstring, added expires field
add 19ad493 Documentation and multiple tasks can be configured.
add 9cff7b2 Merge branch 'develop' into feature/kafkasink
add 746a3bc Kafka connect
add 359fcfc Kafa Sink Connector
add ee15f3b Started to add the documentation to the website
add 5fb8ce4 Started to refactor the source connector validation logic
add 8625533 Refactored Source Validate functions.
add b63951b Refactored Sink Connector Validation and added test cases
add 476ca51 Testing Simulated Driver
add 53ef21b Merge branch 'feature/plc4go' into feature/kafkasink
add af1ed4c Test
add 510f747 Merge remote-tracking branch 'origin/feature/plc4go' into feature/kafkasink
add 450e853 Fixed Simulated reading/writing of lists
add 0e4aa6f Kafka Documentation and cleaning up.
add 1aa3c6f Set each Plc field to optional
add c21b1c2 Updated Fields Struct in Schema.
add 233ea7a Documentation update
add 56150ec Update after Chris's comments
add c5c3223 Minor changes
add 824c791 Found issue with the scraper continuing to run when connector deleted.
new b29a8d7 Merge pull request #202 from apache/feature/kafkasink
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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} | 32 ++-
.../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, 2412 insertions(+), 475 deletions(-)
create mode 100644 plc4j/integrations/apache-kafka/config/plc4x-sink.properties
create mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSinkConnector.java
create mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSinkTask.java
create mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/Constants.java
delete mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/Defaults.java
copy plc4j/{utils/test-utils/src/main/java/org/apache/plc4x/test/driver/model/api/TestField.java => integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/Field.java} (52%)
create mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/Sink.java
create mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/SinkConfig.java
delete mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/exceptions/ConfigurationException.java
create mode 100644 plc4j/integrations/apache-kafka/src/test/java/org/apache/plc4x/kafka/config/SinkConfigTest.java
create mode 100644 plc4j/integrations/apache-kafka/src/test/java/org/apache/plc4x/kafka/config/SinkTaskTest.java
create mode 100644 plc4j/integrations/apache-kafka/src/test/java/org/apache/plc4x/kafka/config/SourceTaskTest.java
create mode 100644 plc4j/integrations/apache-kafka/src/test/java/org/apache/plc4x/kafka/properties/sink_task_no_error.properties
create mode 100644 plc4j/integrations/apache-kafka/src/test/java/org/apache/plc4x/kafka/properties/source_task_no_error.properties
[plc4x] 01/01: Merge pull request #202 from apache/feature/kafkasink
Posted by hu...@apache.org.
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 <be...@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(-)