Как оказалось, инфы в интернете как игл в стоге сена.
Есть ли тут кто нибудь, кто в этом шарит? Michel Angelo, может подскажешь?)
Сделал всё. Есть мессэдж с стринковым свойством(текстом сообщения), есть хэндлер месседжа. dispatch из контроллера создаёт новое сообщение в топик кафки. Но если запустить bin/console messenger:consume async, то чтение сообщения не происходит. Хотя логи с хэндлера выводит, когда создаю сообщение.
Как сделать консумера который прочитает именно сообщение из топика?
посмотри, совпадает ли локальное время и timezone, бывало такое, что сообщения в транспорт попадало с временем на перед, и консьюмер его обрабатывать на 3 часа позже чем я рассчитывал
В таком случае вчерашние сообщения должен сожрать, значит не в этом проблема 😔
может оно зафейлилось?
Тогда бы не отрабатывал хэндлер. Ну а так у меня доктриновская очередь на неудачи, которая пустая, что доказывает отработанность сообщения. Уже неделю борюсь не пойму(
Обсуждают сегодня