This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch 3372-fix-cypress-test-timerangeselectorsspects
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 11de981f5f fix(#3372): Fix test testGroupManagement
add 88396aa1cf feat: Add additional properties to Kafka connectors,
improve logging (#3378)
add 19736fd9e9 Merge branch 'dev' into
3372-fix-cypress-test-timerangeselectorsspects
No new revisions were added by this update.
Summary of changes:
.../kafka/KafkaConnectorsModuleExport.java | 6 ++++-
.../connectors/kafka/adapter/KafkaProtocol.java | 24 ++++++++++-------
.../kafka/migration/KafkaAdapterMigrationV2.java} | 30 ++++++++++++----------
...kMigrationV1.java => KafkaSinkMigrationV2.java} | 21 +++++++++------
.../kafka/shared/kafka/KafkaConfigExtractor.java | 27 +++++++++++++++++++
.../kafka/shared/kafka/KafkaConfigProvider.java | 1 +
.../connectors/kafka/sink/KafkaPublishSink.java | 8 +++++-
.../strings.en | 3 +++
.../documentation.md | 5 ++--
.../strings.en | 3 +++
.../integration/adapters/KafkaAdapterTester.java | 2 +-
...nfigAppender.java => SimpleConfigAppender.java} | 14 ++++++++--
.../KafkaSecurityProtocolConfigAppender.java | 30 ++++++++++++----------
.../template/PipelineElementTemplateVisitor.java | 1 +
.../connect/RuntimeResolvableResource.java | 5 ++++
15 files changed, 129 insertions(+), 51 deletions(-)
copy
streampipes-extensions/{streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV1.java
=>
streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/migration/KafkaAdapterMigrationV2.java}
(68%)
copy
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/migration/{KafkaSinkMigrationV1.java
=> KafkaSinkMigrationV2.java} (75%)
copy
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/{KafkaConfigAppender.java
=> SimpleConfigAppender.java} (72%)
