Я пытаюсь запустить Apache Samza 0.14.0 с включенным P
plain SASL (not GSSAPI) Kafka 0.10.1.1. Мне кажется, что это поддерживается (через Kafka API), но не в org.apache.samza.system.kafka.KafkaSystemConsumer.
Этот классне использует API Kafka напрямую, но через org.apache.samza.system.kafka.BrokerProxy и более поздние версии org.apache.samza.system.kafka.DefaultFetchSimpleConsumer.
Этот класс (DefaultFetchSimpleConsumer) использует SimpleConsumer из API Kafka.
Из того, что я нашелв источниках samza-kafka конфигурация sasl не передается SimpleConsumer, и SimpleConsumer пытается получить доступ к Kafka без включенного SASL.
Эта проблема возникает, когда samza запущена и текущие настройки повторно считаны из координатора samzasтема.Это происходит только с потребителем-координатором, производитель-координатор передает конфигурацию производителя SASL (фактически всю) производителю API-интерфейсов Kafka.
У меня вопрос: могу ли я что-то упустить в конфигурации или SASL не поддерживается вСамза или ...
Thx.