Коллеги, подскажите, пожалуйста, как сделать табличку для кафки с простой

Question

Коллеги, подскажите, пожалуйста, как сделать табличку для кафки с простой

авторизацией?

Создаю табличку:

CREATE TABLE streams.kafka_test (
ip LowCardinality(String),
ts Int64,
list_like_string String
) engine Kafka SETTINGS kafka_broker_list = 'kafka:9092',
kafka_topic_list = 'my-topic',
kafka_group_name = 'my-group',
kafka_format = 'JSONEachRow',
kafka_num_consumers = 1;

Делаю конфиг:

[```root@test-03 clickhouse-server]# cat config.d/kafka.xml
<?xml version="1.0"?>
<yandex>
<kafka>
<sasl_mechanism>PLAIN</sasl_mechanism>
<security_protocol>SASL_PLAINTEXT</security_protocol>
<sasl_username>kafka-user</sasl_username>
<sasl_password>password</sasl_password>
</kafka>
</yandex>
Пытаюсь прочитать:

s```elect *
from streams.kafka_test limit 1;
Результатов нет, но данные в топике точно есть.

В логе такие ошибки:

2020.12.17 02:38:04.163667 [ 375848 ] {9093ed7f-afbc-4e54-824b-cfef0575f4f4} <Warning> StorageKafka (kafka_shk_tracker): Can't get assignment. It can be caused by some issue with consumer group (not enough partitions?). Will keep trying.
2020.12.17 02:38:09.560303 [ 418370 ] {} <Error> StorageKafka (kafka_shk_tracker): [rdk:ERROR] [thrd:10.41.50.13:9092/bootstrap]: 1/1 brokers are down