вы clickhouse На тот же сервер на котором kafka крутится поставили?
нет, На другой, и они и были на разных
я порты про бросил на сервер клиrа ,Чтоб они ходил на localhost:9092
тогда непонтяно, почему вы решили что ошибки при чтении от локального коннекта 127.0.0.1 внутри kafka server относятся к clickhouse? если бы относились тогда бы там IP clickhouse-server был в самой кафке ничего не меняли?
когда делаю detach - эта ошибка пропадает
прокинул порты наружу кубера каким способом?
ок. понятно тогда да, связано... как прокидывали порты из кубера на сервер клика?
да, я через порт форвардинг прокинул. и по логахего вижу ,То данные идут вот так - пока костально: oc port-forward service/qa-kafka-bootstrap 9094:9092 проверял питоном, что могу запросить списки топиков, и принял решение, что работает такой способ)
ну он работает ... то есть clickhouse-server ходит на 127.0.0.1:9094 ? в логах /var/log/clickhouse/clickhouse-server.err.log что то есть?
вообще port-forward это способ "временного прокидывания" для отладки обычно... как вы проверяете что oc все еще запущен и форвардит трафик?
да, на 9094 ходит и могу видеть топики. в логах много чего есть, на том сервере, крутятся другие базы. поэтому найти именносои ошибки сложно. вижу только типа таких 2022.08.22 05:34:26.013990 [ 822377 ] {} <Error> void DB::StorageKafka::threadFunc(size_t): Code: 242, e.displayText() = DB::Exception: Table is in readonly mode (zookeeper path: /clickhouse/tables/qa/user_activities), Stack trace (when copying this message, always include the lines below):
оно сейчас откорыто в отдельном окне, не в фоне и я вижу, когда идет потом или ,он в аутпут плюет такое, когда идет поток
у вас коннект к zookeeper пропал... для ReplicatedMergeTree таблиц zookeeper нужен судя по всему engine=Kafka пытается вычитать данные из кафки и Materialized View который тригерит это вычитывание, не может вставить данные в destination ReplicatedMergeTree и Engine=Kafka закрывает соединение с kafka .... почитайте тут как это работает https://kb.altinity.com/altinity-kb-integrations/altinity-kb-kafka/altinity-kb-kafka-main-parsing-loop/
понля, спасибо - гляну. на зукипере , правад ,тоже поднимал проброс, чтоб он видел
проверьте SELECT * FROM system.zookeeper WHERE path='/' FORMAT Vertical
у кафка есть понятие advertised listeners т.е. вы говорите консюмеру (kafka=engine) иди на localhost:9092 , он туда идет, а там ему говорят тебе надо ходит в брокеры с именами, x:19092, y:19092, z:19092, ...., а КХ туда подключится не может, потому что вы их не пробросили, или имена совсем левые получаются
да, точно - спасибо - может такое быть
Обсуждают сегодня