брокер c sasl_ssl
kafka-reassign-partitions.sh connect to kafka sasl_ssl broker?
если у вас вопрос как конектится к кластеру с sasl_ssl, то у каждой консольной утилиты (kafka-topic.sh kafka-config.sh etc) есть опция --command-config, куда вы передаете конфиг со всеми опциями подключения - протокол, механизм, сертификаты, юзер\пароль у меня для scram это выглядит так sasl.mechanism=SCRAM-SHA-256 security.protocol=SASL_SSL ssl.truststore.location=/path_to_cert/truststore.jks ssl.truststore.password=qazwsx123 sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \ username="user" \ password="password";
Спасибо. уже разобрался.
Обсуждают сегодня