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

Всем привет! у меня в config.xml есть секция kafka, где описаны

креды (логин\пароль).
далее, есть таблица с engine=kafka и там описаны брокеры, топики и т.д.
подскажите, можно ли как то создать новую таблицу и настроить на ней авторизацию в кафке по сертам не ломая авторизацию по логину\паролю для существующих таблиц?

10 ответов

8 просмотров

Можно либо конфигурять отдельно каждый топик <kafka_$topic>, либо вынести конфигурацию в named collections, тогда конфигурять движок можно будет ссылаясь на конкретную секцию конфига. Пример: https://pastila.nl/?038029e6/3cb002a547c30d2795d42a998455f137

Ivan- Автор вопроса
Илья Коргун
Можно либо конфигурять отдельно каждый топик <kafk...

о! супер! спасибо) а есть пример как законфигурить ссл по серту? в документации нашел только сасл и по паролю

Ivan
о! супер! спасибо) а есть пример как законфигурить...

Движок использует librdkafka, все опции из конфига мапятся на опции библиотеки. Дока библиотеки: https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md

Ivan- Автор вопроса

не прокатило. таблица пустая, хотя в топике сообщения есть. нашел в логах это: failed to resolve 'kafka_ssl:9092' Name or service not know

Ivan- Автор вопроса
Ivan
какой? kafka_ssl? нет

А где он тогда прописан и зачем?

Ivan- Автор вопроса
Илья Коргун
А где он тогда прописан и зачем?

так это не хостнейм. в named_collections прописан конфиг для авторизации в кафке и называется он kafka_ssl. далее я на него ссылаюсь при создании таблицы: ENGINE=Kafka('kafka_ssl') вот так https://clickhouse.com/docs/ru/operations/named-collections а в логах я вижу что кликхаус его пытается резолвить, как хост

Ivan
так это не хостнейм. в named_collections прописан ...

Не в стринге. Просто Kafka(kafka_ssl) и кликхаус обновить, видимо

Ivan- Автор вопроса

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

Обсуждают сегодня

А чем вам питонисты не угодили?😂
.
79
Всем привет, написал код ниже, но он выдает сегфолт, в чем причина? #include <stdio.h> #include <stdlib.h> #include <string.h> struct product { char *name; float price; };...
buzz базз
75
Ребят, а за скок можно впарить анон чат с апишкой и веб админкой ?
Eugene Неелов
15
Ещё такой вопрос. Мне необходимо хранить пароль пользователя локально. Для этого планирую использовать ini файл. Это для автозаполнения полей логин и пароль при авторизации. Е...
Евгений
19
Anyone knows how to build this widget in Flutter? I have all the assets for round stations and the road, but how can I make the my widget animate between these stations? And h...
Mohammad Zamani
9
короче я не выдержал постоянно определять структуры, чтобы возвращать массивы разных типов. Как обычно еще это делают?
Павλо 🇺🇦
7
Если у очереди установлено x-message-ttl, при получении сообщения из этой очереди, можно узнать остаток времени жизни сообщения?
Сергей
8
Подскажите как мне лучше держать websocket сединение и переодически передавать в него данные? Сначала я сделал так: for _ in 1...1000 { try? await ws.send("test") try...
Mihail Verenich
2
Ты просто гитлеровскую эстетику плохо понимаешь. Он же всё под Цезаря делал. А это как бы запрещённый приём в политике. Пиджаки они зачем все носят? Чтобы показать что они тип...
Ivan Kropotkin
4
А цены чем оправданы?
Lencore
7
Карта сайта