Может кто подсказать, есть ли какая-то особенность по настройке RabbitMQ

+ ClickHouse внутри одного композ файла (в общую сеть добавил)?


Интересную ошибку ловлю в реббите:
04-10 14:08:11 2024-04-10 10:08:11.918411+00:00 [error] <0.9369.0> closing AMQP connection <0.9369.0> (172.22.0.3:46446 -> 172.22.0.2:5672):
2024-04-10 14:08:11 2024-04-10 10:08:11.918411+00:00 [error] <0.9369.0> missed heartbeats from client, timeout: 60s

И ещё в клике:
2024.04.10 09:30:57.320792 [ 1 ] {} <Error> StorageRabbitMQ (log_rabbitmq): Consumer failed on channel 1_0_zqjlxdowuxmpekupjxinglzbqzvuxsee. Reason: Channel is in error state
2024.04.10 09:30:57.321310 [ 1 ] {} <Error> StorageRabbitMQ (log_rabbitmq): Channel 1_0_zqjlxdowuxmpekupjxinglzbqzvuxsee in an error state: connection lost
2024.04.10 09:30:57.322226 [ 1 ] {} <Error> StorageRabbitMQ (log_rabbitmq): Library error report: connection lost
2024.04.10 09:30:57.328107 [ 1 ] {} <Error> StorageRabbitMQ (log_rabbitmq): Consumer failed on channel 1_0_lpcngbhratbkhhswhoejylwjspocbnsb. Reason: Channel is in error state
2024.04.10 09:30:57.328795 [ 1 ] {} <Error> StorageRabbitMQ (log_rabbitmq): Channel 1_0_lpcngbhratbkhhswhoejylwjspocbnsb in an error state: connection lost
2024.04.10 09:30:57.329209 [ 1 ] {} <Error> StorageRabbitMQ (log_rabbitmq): Library error report: connection lost

При этом свои служебные очереди, обменники и бинды клик делает при создании таблицы с RabbitMQ engine, а вот в consumers уже не висит в своей очереди (хотя должен), следовательно, оттуда не берет сообщения...(

5 ответов

47 просмотров

могу только подсказать что реализация реббита в клиеке - отвратительная, лучше выбросить и сделать свою

мне кажется мы с вами это уже обсуждали

Виктор-FabulouS Автор вопроса
Aleksey Barabanov
мне кажется мы с вами это уже обсуждали

Не совсем. Я на серваках запустил и отлично работает.

Виктор-FabulouS Автор вопроса
Виктор FabulouS
Не совсем. Я на серваках запустил и отлично рабо...

Я бы даже сказал, что выручил реббит очень сильно. Больше не ловлю ошибки от клика и все бизнес-логи сохранены! 😊

Виктор-FabulouS Автор вопроса

Нашел! Нашел нашел нашел! У меня DDL файл частично применился и не создалось Materialized Views!!!

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

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

А если для werf организовать отдельный репозиторий, а сервисы из проекта подключить как симлинки? И симлинки в гитигнор добавить?
Dmitriy Andreev
13
Всем здравствуйте!) У меня такой вопрос. Есть два роута, роут1 и роут2. Они связаны с очередью some_queue. По задаче предполагается, что есть два паблиша. Паблиш1 отправляет...
Format
10
Ребят, всем привет. Недавно начал знакомиться с werf с целью автоматизировать сборку локальных dev стендов. Прошел гайд, почитал статьи на хабре. Появилось некоторое понимание...
Dmitriy Andreev
4
всем привет, подскажите, может есть способ срендерить чарт с помощью werf, указав при этом реджистри, в который нет доступа? дело в том, что по политике безопасности мне нужно...
Alexandr Alexandr
1
Всем привет!Пытаюсь поставить плагин rabbitmq-delayed-message-exchange:latest Ошибка: Feature flags: stream_single_active_consumer: required feature flag not enabled! It must...
Nex1n [CHECK_BIO]
2
всем привет, не работал с buildah, подскажите что нужно сделать чтобы включить staged: true для докерфайла? Сейчас получаю ошибку: Staged build of Dockerfile is not available ...
Alexandr Alexandr
5
Всем привет, есть ли возможность как то приоритизировать сообщение в очереди, то есть по сути класть в начало , у нас есть что то что 5, очередь ->1,3,2-> по обычному ->5,1,3...
Pepel📰
2
Еще одну панику поймал: $ werf helm repo add --username gitlab --password ${CI_JOB_TOKEN} helm-werf ${HELM_REPO_V2_URL} "helm-werf" has been added to your repositories $wer...
citius
1
Блин а мне как поумнеть ?
Toxin
191
Вот такая неприятность на stable и ea версиях: werf helm --namespace s4c upgrade --install --atomic --timeout 5m --set s4c.version=839185f3 --set s4c.deployEnv=staging -f d...
citius
6
Карта сайта