Команда запустить чтение и обработку стрима (не указывайте topic для процессинга всех)
$ muffin vibe streams <topic>Чтобы перечитать топик с начала задайте новый group id
$ muffin vibe streams <topic> --group-id=NewGroupIDЧтобы читать с какого-либо offset:
$ muffin vibe streams <topic> --offset=<offset>Меняйте GROUP_ID если сбрасываете offset
Иначе повлияете на offset для production (тк по умолчанию GROUP ID берется из настроек)
Переменные окружения
- VIBE_IMPORT_ORDERS_LIFETIME_DELTA - время жизни заказа (сек). Заказы старше этой дельты будут считаться просроченными и не будут обрабатываться
- VIBE_IMPORT_ORDERS_ONLY_EVENT - обрабатывать заказы только из этого мероприятия (external_id)