kafka-console-продюсер с керберосом бросает security-protocol не опознан

Question

Я включил Kerberos из Ambari v2.7.3 и HDP v3.1.0 для всех сервисов Hadoop. Я проверил аутентификацию HBase с использованием NIFI. Мне нужно также проверить Кафку. В консоли Кафки я могу создать тему. Но при производстве и потреблении я сталкиваюсь с ошибкой, как показано ниже.

security-protocol is not a recognized option

Ниже приведена команда производителя Kafka, которую я пробовал

/usr/hdp/3.1.0.0-78/kafka/bin/kafka-console-producer.sh --broker-list HOSTNAME:6667 --topic test_new_topic --security-protocol SASL_PLAINTEXT

Answer 1

Я бы посоветовал добавить все свойства в один файл (например, client-ssl.properties) со следующим содержимым:

security.protocol=SASL_PLAINTEXT

и, наконец, использовать –-producer.config для передачи файла свойств в консоль.производитель:

/usr/hdp/3.1.0.0-78/kafka/bin/kafka-console-producer.sh –-broker-list HOSTNAME:6667 –-topic test_new_topic –-producer.config client-ssl.properties

Если вы не хотите использовать файл свойств, вы можете использовать --producer-property для передачи конфигурации security.protocol:

/usr/hdp/3.1.0.0-78/kafka/bin/kafka-console-producer.sh --broker-list HOSTNAME:6667 --topic test_new_topic  --producer-property security.protocol=SASL_PLAINTEXT

Answer 2

Используйте --property с именами свойств следующим образом:

/usr/hdp/3.1.0.0-78/kafka/bin/kafka-console-producer.sh --broker-list HOSTNAME:6667 --topic test_new_topic  --property security.protocol=SASL_PLAINTEXT