Hey all, I added username/password authentication to the Kafka connect adapter and the Kafka sink. While the unauthenticated version is still available, we now have the additional option to publish and consume from a username/password secured broker. See also https://docs.confluent.io/platform/current/kafka/authentication_sasl/authentication_sasl_plain.html for additional information.
You find the PRs here: • https://github.com/apache/incubator-streampipes-extensions/pull/32 • https://github.com/apache/incubator-streampipes/pull/28 Currently, however, username and password are sent in plaintext, thus I will add TLS encryption in the near future. Best Marco
