Всем привет, подскажите плиз, хочу подключиться CH к кафка бутстрап

Question

Всем привет, подскажите плиз, хочу подключиться CH к кафка бутстрап

серверу, получаю такую ошибку
Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 4ms in state APIVERSION_QUERY, 3 identical error(s) suppressed)
Вот таким образом подключаюсь:

<yandex>
<named_collections>
<kafka_streaming_bet_approved>
<kafka_broker_list from_env="KAFKA_BROKER_LIST"/>
<security_protocol from_env="KAFKA_SECURITY_PROTOCOL"/>
<sasl_mechanism from_env="KAFKA_SASL_MECHANISM"/>
<sasl_username from_env="KAFKA_SASL_USERNAME"/>
<sasl_password from_env="KAFKA_SASL_PASSWORD"/>
<kafka_topic_list>streaming.bet_approved.v1</kafka_topic_list>
<kafka_group_name>clickhouse.streaming.bet_approved.v1</kafka_group_name>
</kafka_streaming_bet_approved>
<kafka_logs_payout_kafka>
<kafka_broker_list from_env="KAFKA_BROKER_LIST"/>
<security_protocol from_env="KAFKA_SECURITY_PROTOCOL"/>
<sasl_mechanism from_env="KAFKA_SASL_MECHANISM"/>
<sasl_username from_env="KAFKA_SASL_USERNAME"/>
<sasl_password from_env="KAFKA_SASL_PASSWORD"/>
<kafka_topic_list>logging.history.payout.v1</kafka_topic_list>
<kafka_group_name>clickhouse_group</kafka_group_name>
</kafka_logs_payout_kafka>
</named_collections>
</yandex>

В чем я не прав?

#backend #clickhouse #database #devops #programming #russian

0

14.04.2022

1 ответов

21 просмотр

Edgar Zhivaev · Accepted Answer

Edgar Zhivaev

Столкнулся с такой же ошибкой. Спустя год не вспомнишь, как решил в итоге?)

0

11 месяцев назад

184 похожих чатов

Всем привет, подскажите плиз, хочу подключиться CH к кафка бутстрап

1 ответов

Похожие вопросы