креды (логин\пароль).
далее, есть таблица с engine=kafka и там описаны брокеры, топики и т.д.
подскажите, можно ли как то создать новую таблицу и настроить на ней авторизацию в кафке по сертам не ломая авторизацию по логину\паролю для существующих таблиц?
Можно либо конфигурять отдельно каждый топик <kafka_$topic>, либо вынести конфигурацию в named collections, тогда конфигурять движок можно будет ссылаясь на конкретную секцию конфига. Пример: https://pastila.nl/?038029e6/3cb002a547c30d2795d42a998455f137
о! супер! спасибо) а есть пример как законфигурить ссл по серту? в документации нашел только сасл и по паролю
Движок использует librdkafka, все опции из конфига мапятся на опции библиотеки. Дока библиотеки: https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md
не прокатило. таблица пустая, хотя в топике сообщения есть. нашел в логах это: failed to resolve 'kafka_ssl:9092' Name or service not know
А этот хостнейм резолвится?
какой? kafka_ssl? нет
А где он тогда прописан и зачем?
так это не хостнейм. в named_collections прописан конфиг для авторизации в кафке и называется он kafka_ssl. далее я на него ссылаюсь при создании таблицы: ENGINE=Kafka('kafka_ssl') вот так https://clickhouse.com/docs/ru/operations/named-collections а в логах я вижу что кликхаус его пытается резолвить, как хост
Не в стринге. Просто Kafka(kafka_ssl) и кликхаус обновить, видимо
без кавычек выдает ошибку
Обсуждают сегодня