You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by cd...@apache.org on 2019/08/24 17:50:29 UTC
[plc4x] branch develop updated (a660a46 -> 74c892c)
This is an automated email from the ASF dual-hosted git repository.
cdutz pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git.
from a660a46 - Changed the deploy phase to run on a node labeled: nexus-deploy
add 39ccdcb - Working on refactoring the Kafka Connect configuration.
add bc226ac Merge branch 'develop' of https://gitbox.apache.org/repos/asf/plc4x into featule/kafka-connect-refactoring
add 328a943 - Removed the kafka connect sink
add 7c0303f - Continued working on the scraper based Kafka Connect plugin
add 7450a29 - Continued working on the scraper based Kafka Connect plugin - Added an assembly that also merges the services files
add 548d772 - Got a first working scraper-based Kafka Connect Source working
add 639c5e8 Merge branches 'develop' and 'featule/kafka-connect-refactoring' of https://gitbox.apache.org/repos/asf/plc4x into featule/kafka-connect-refactoring
add b649586 Merge branches 'develop' and 'featule/kafka-connect-refactoring' of https://gitbox.apache.org/repos/asf/plc4x into featule/kafka-connect-refactoring
add 74c892c - Finished a first fully operational version of the Kafka Connect Source
No new revisions were added by this update.
Summary of changes:
plc4cpp/pom.xml | 7 +-
plc4j/integrations/apache-kafka/README.md | 60 +++-
.../apache-kafka/config/sink.properties | 25 --
.../apache-kafka/config/source.properties | 59 ++--
plc4j/integrations/apache-kafka/pom.xml | 117 +++++--
.../apache-kafka}/src/assembly/assembly.xml | 3 +-
.../org/apache/plc4x/kafka/Plc4xSinkConnector.java | 77 -----
.../java/org/apache/plc4x/kafka/Plc4xSinkTask.java | 116 -------
.../apache/plc4x/kafka/Plc4xSourceConnector.java | 140 ++++----
.../org/apache/plc4x/kafka/Plc4xSourceTask.java | 351 +++++++++++----------
.../org/apache/plc4x/kafka/config/Defaults.java | 14 +-
.../java/org/apache/plc4x/kafka/config/Job.java | 23 +-
.../apache/plc4x/kafka/config/JobReference.java | 20 +-
.../java/org/apache/plc4x/kafka/config/Source.java | 20 +-
.../apache/plc4x/kafka/config/SourceConfig.java | 160 ++++++++++
.../kafka/exceptions/ConfigurationException.java} | 10 +-
.../plc4x/kafka/config/SourceConfigTest.java | 78 +++++
.../JobConfigurationTriggeredImplBuilder.java | 2 +-
.../triggeredscraper/TriggeredScraperTask.java | 1 -
plc4py/src/main/python/__init__.py | 9 -
20 files changed, 717 insertions(+), 575 deletions(-)
delete mode 100644 plc4j/integrations/apache-kafka/config/sink.properties
copy plc4j/{utils/interop => integrations/apache-kafka}/src/assembly/assembly.xml (91%)
delete mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSinkConnector.java
delete mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSinkTask.java
copy sandbox/code-gen/src/main/java/org/apache/plc4x/codegen/ast/Expression.java => plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/Defaults.java (77%)
copy sandbox/code-gen/src/main/java/org/apache/plc4x/codegen/ast/ParameterExpression.java => plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/Job.java (66%)
copy sandbox/code-gen/src/main/java/org/apache/plc4x/codegen/ast/ParameterExpression.java => plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/JobReference.java (70%)
copy sandbox/code-gen/src/main/java/org/apache/plc4x/codegen/ast/ParameterExpression.java => plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/Source.java (64%)
create mode 100644 plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/SourceConfig.java
copy plc4j/{api/src/main/java/org/apache/plc4x/java/api/exceptions/PlcUnsupportedOperationException.java => integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/exceptions/ConfigurationException.java} (75%)
create mode 100644 plc4j/integrations/apache-kafka/src/test/java/org/apache/plc4x/kafka/config/SourceConfigTest.java