pika.exceptions.ChannelClosedByBroker: (406, "PRECONDITION_FAILED - inequivalent arg 'x-message-ttl' for queue 'amo-crm.q' in vhost '/': received the value '60000' of type 'si...
https://habr.com/ru/companies/domclick/articles/500978/ Добрый день, подскажите, пожалуйста, насколько хорошая практика сделать вот такую структуру эксчейнджей и очередей для...
Всем привет, подскажите, пожалуйста, что произойдёт при вызове метода queue_declare с одним и тем же именем очереди, но с разными остальными параметрами? Создастся ли новая оч...
Привет, подскажите, как я могу отправить через кафку словарь по типу {"id": 0, "file": file}, где file это объект werzeug.datastructures.FileStorage, ну то есть файл, полученн...
По сути, все, что угодно, можно в документации найти, тогда смысл этой группы будет в том, чтобы все отвечали: "омг, иди в доку, лох"?
Ребята, кто-нибудь работал с rabbitmq? Поставьте плюсики, пожалуйста, кто шарит, у кого есть адекватный пример паблишера и консюмера, желательно, чтобы рэббит и консюмер крути...
WARNING:kafka.coordinator:Heartbeat failed for group group because it is rebalancing WARNING:kafka.coordinator.assignors.range:No partition metadata for topic my_topic Один ва...
У меня консюмер по задумке загружает файл на s3, а из кафки он уйдет сразу же после обработки сообщения, нет?