search

zalando / nakadi

A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues
https://nakadi.io
MIT License
952 stars 292 forks source link

Implement optional settings that enable Nakadi security #1525

Closed tor-vs-floki closed 1 year ago

tor-vs-floki commented 1 year ago

Introduce SECURITY_PROTOCOL, SASL_MECHANISM, KAFKA_USERNAME and KAFKA_PASSWORD Nakadi settings that will allow Nakadi to configure Kafka clients with security SASL Plain username + password.

Nakadi discovers the list of Brokers by looking in all registered storages entries in Zookeeper, and iterates /brokers/ids to discover every broker IP address and Port. This PR introduces PREFERRED_LISTENER_PORT setting that allow Nakadi to connect to different listeners in Kafka(previously would connect to the port available in Zookeeper entry, which is the first port of all available listeners, and also an internal Zookeeper structure).

adyach commented 1 year ago

👍

tor-vs-floki commented 1 year ago

👍