серверу, получаю такую ошибку
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>
В чем я не прав?
Столкнулся с такой же ошибкой. Спустя год не вспомнишь, как решил в итоге?)
Обсуждают сегодня