Потоки Redis - XCLAIM ничего не возвращает?

Я обрабатываю сообщения в потоке Redis через группы потребителей. В конечном итоге они могут выйти из строя, поэтому полученные сообщения останутся ожидающими навсегда. Я хотел бы реализовать потребителей, которые повторно обрабатывают эти сообщения через определенное время.

Сначала я получаю ожидающие сообщения:

XPENDING mystream mygroup - + 5
1) {"id":"1589686206685-0","consumerName":"d14b500b-e503-463e-9a1e-2da1ea7ba30b","elapsedMilliseconds":3097640,"deliveryCount":1}
2) {"id":"1589686230937-0","consumerName":"2e2e2df9-fda5-4ad5-a3ce-4ddaaf545475","elapsedMilliseconds":3073388,"deliveryCount":1}
3) {"id":"1589686230944-0","consumerName":"998994b3-8c83-4259-8daa-63bbcd6aa518","elapsedMilliseconds":3073380,"deliveryCount":1}
4) {"id":"1589686230945-0","consumerName":"b1c0462e-e535-4cc0-bb16-76ff5fc529e6","elapsedMilliseconds":3073380,"deliveryCount":1}
5) {"id":"1589686230947-0","consumerName":"bc2b73d0-a7ef-4121-8f62-4b4e05e8d6d9","elapsedMilliseconds":3073378,"deliveryCount":1}

Но теперь, когда я пытаюсь заявить права на любую из них одному из этих новых потребителей:

XCLAIM mystream mygroup newconsumer 0 1589686206685-0

Я получаю пустой ответ. Ожидается ли такое поведение и почему?

0 ответов

Другие вопросы по тегам