This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch 3355-add-new-avro-format-parser
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 719d1d2222 Merge branch 'dev' into 3355-add-new-avro-format-parser
add 2edc5e50aa feat(#3362): Add SSL/SASL support to Kafka adapter and sink
(#3364)
No new revisions were added by this update.
Summary of changes:
pom.xml | 2 +-
.../apache/streampipes/commons/constants/Envs.java | 16 +-
.../constants/GlobalStreamPipesConstants.java | 1 +
.../commons/environment/DefaultEnvironment.java | 42 +++-
.../commons/environment/Environment.java | 39 +---
.../connectors/kafka/adapter/KafkaProtocol.java | 84 ++++----
.../kafka/shared/kafka/KafkaAdapterConfig.java | 17 +-
.../{KafkaConfig.java => KafkaBaseConfig.java} | 51 ++---
.../kafka/shared/kafka/KafkaConfigExtractor.java | 121 ++++++++++++
.../kafka/shared/kafka/KafkaConfigProvider.java | 153 +++++++++++++++
.../kafka/shared/kafka/KafkaConnectUtils.java | 211 ---------------------
.../connectors/kafka/sink/KafkaParameters.java | 90 ---------
.../connectors/kafka/sink/KafkaPublishSink.java | 49 ++---
.../strings.en | 19 +-
.../strings.en | 3 +
.../opcua/config/security/KeyStoreLoader.java | 2 +-
.../integration/adapters/KafkaAdapterTester.java | 8 +-
.../kafka/config/KafkaConfigAppender.java | 4 +-
.../kafka/security/KafkaSecurityConfig.java | 25 ---
.../KafkaSecurityProtocolConfigAppender.java | 70 +++++++
...g.java => KafkaSecuritySaslConfigAppender.java} | 40 +++-
.../kafka/security/KafkaSecuritySaslSSLConfig.java | 51 -----
.../KafkaSecurityUnauthenticatedPlainConfig.java | 29 ---
.../KafkaSecurityUnauthenticatedSSLConfig.java | 32 ----
.../impl/connect/RuntimeResolvableResource.java | 2 +
...tic-runtime-resolvable-oneof-input.component.ts | 37 +++-
26 files changed, 573 insertions(+), 625 deletions(-)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/ElementNotFoundException.java
=>
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaAdapterConfig.java
(74%)
rename
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/{KafkaConfig.java
=> KafkaBaseConfig.java} (50%)
create mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaConfigExtractor.java
create mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaConfigProvider.java
delete mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaConnectUtils.java
delete mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/sink/KafkaParameters.java
delete mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecurityConfig.java
create mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecurityProtocolConfigAppender.java
rename
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/{KafkaSecuritySaslPlainConfig.java
=> KafkaSecuritySaslConfigAppender.java} (50%)
delete mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecuritySaslSSLConfig.java
delete mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecurityUnauthenticatedPlainConfig.java
delete mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecurityUnauthenticatedSSLConfig.java
