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
