diff --git a/streampipes-extensions/streampipes-connectors-kafka/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.kafka/strings.en b/streampipes-extensions/streampipes-connectors-kafka/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.kafka/strings.en index 0d73d6d2f4..c4cef7cf4e 100644 --- a/streampipes-extensions/streampipes-connectors-kafka/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.kafka/strings.en +++ b/streampipes-extensions/streampipes-connectors-kafka/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.kafka/strings.en @@ -39,13 +39,13 @@ password.description=The password to authenticate with the broker access-mode.title=Access Mode access-mode.description=Unauthenticated or SASL/PLAIN -unauthenticated-plain.title=Unauthenticated Plain +unauthenticated-plain.title=PLAINTEXT unauthenticated-plain.description=No authentication and plaintext -unauthenticated-ssl.title=Unauthenticated SSL +unauthenticated-ssl.title=SSL unauthenticated-ssl.description=Using SSL with no authentication -sasl-plain.title=SASL/PLAIN +sasl-plain.title=SASL/PLAINTEXT sasl-plain.description=Username and password, no encryption sasl-ssl.title=SASL/SSL diff --git a/ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts b/ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts index 7029ac309a..51d149369b 100644 --- a/ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts +++ b/ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts @@ -35,7 +35,7 @@ describe('Test Kafka Integration', () => { const sink: PipelineElementInput = PipelineElementBuilder.create( 'kafka_publisher', ) - .addInput('radio', 'access-mode-unauthenticated_plain', '') + .addInput('radio', 'access-mode-plaintext', '') .addInput('input', 'host', host) .addInput( 'input', @@ -48,7 +48,7 @@ describe('Test Kafka Integration', () => { const adapter = AdapterBuilder.create('Apache_Kafka') .setName('Kafka4') .setTimestampProperty('timestamp') - .addProtocolInput('radio', 'access-mode-unauthenticated_plain', '') + .addProtocolInput('radio', 'access-mode-plaintext', '') .addProtocolInput('input', 'host', host) .addProtocolInput('input', 'port', port) .addProtocolInput('click', 'sp-reload', '')