22.3)?
Например добавляю:
<named_collections>
<kafka_collection>
<security_protocol>SASL_PLAINTEXT</security_protocol>
<sasl_kerberos_keytab>/etc/clickhouse-server/clickhouse.keytab</sasl_kerberos_keytab>
<sasl_kerberos_principal>user@DOMAIN</sasl_kerberos_principal>
</kafka_collection>
</named_collections>
Создаю таблицу:
CREATE TABLE default.tablename
(NAME1 String, NAME2 UInt32, NAME3 UInt32, NAME4 Nullable(String), NAME5 Nullable(String))
ENGINE = Kafka(kafka_collection) SETTINGS kafka_broker_list = 'broker:6667',
kafka_topic_list = 'topicname',
kafka_group_name = 'topicname.ch_cl',
kafka_format = 'AvroConfluent',
format_avro_schema_registry_url = 'http://registry:8081'
а в логе клик пишет что не может подключиться т.к. не увидел security_protocol:
2022.08.02 11:08:08.227880 [ 147341 ] {} <Information> StorageKafka (topicname): [rdk:FAIL] [thrd:broker:6667/bootstrap]: broker:6667/bootstrap: Disconnected: verify that security.protocol is correctly configured, broker might require SASL authentication (after 0ms in state UP)
2022.08.02 11:08:08.227931 [ 147341 ] {} <Error> StorageKafka (topicname): [rdk:ERROR] [thrd:broker:6667/bootstrap]: 1/1 brokers are down
Причем если попытаться указать несуществующую коллекцию, то он ругается при создании таблицы, т.е. сама фича в данной версии имеется.
Пробывали переопределить его ? После указа named_collections
Переопределить что?
Почитав всё ещё раз, пришёл к выводу, что named_collections вы используете не правильно, и так делать нельзя
Обсуждают сегодня