проверка подлинности реестра схемы слияния с использованием clickhouse с механизмом кафки

#apache-kafka #basic-authentication #apache-kafka-connect #clickhouse #confluent-schema-registry

Вопрос:

Я хочу использовать сообщения в формате AvroConfluent из темы kafka и хранить их в таблице clickhouse, поэтому я создал таблицу с помощью движка kafka и ввел URL-адрес реестра схемы в настройках таблицы, но серверу реестра схемы требуется базовая аутентификация, в которой я не уверен, где и как мне следует размещать информацию о пользователе. как и конфигурация аутентификации кафки, я попытался ввести свою информацию в config.xml файл для clickhouse-сервера, но, по-видимому, он не работает

1. не могли бы вы предоставить xml-конфигурацию, сообщение об ошибке и т. Д.?

2. Пожалуйста, отредактируйте вопрос, чтобы ограничить его конкретной проблемой с достаточной детализацией для определения адекватного ответа.

Ответ №1:

Чтобы определить учетные данные для аутентификации, ему необходимо:

открыть config.xml

 sudo nano /etc/clickhouse-server/config.d/config.xml

расширьте элемент кафки на требуемые параметры:

 <kafka>
    <security_protocol>sasl_plaintext</security_protocol>
    <sasl_mechanism>PLAIN</sasl_mechanism>
    <sasl_username>test</sasl_username>
    <sasl_password>test</sasl_password>
    <!-- .. -->
</kafka>

перезапустите службу clickhouse

 sudo service clickhouse-server restart

Подробнее см. https://altinity.com/blog/clickhouse-kafka-engine-faq.