определеную партицию топика? даже ребаланс был, партиция была отдана другому инстансу, но все равно по одной партиции висит большой лаг, так еще и увеличивается. остальные партиции читаются нормально.
Вообще не читается?
тут проблематично, тк клиентский приклад я не вижу и логи не могу посмотреть, я только со стороны кафки видел, что лаг растет, но конечно возможно, что какая-то вычитка идет. типа одно сообщение не может десериализовать и потому вся обработка встала? ок, посмотрим вместе с клиентами, спасибо.
Так ты в кафке посмотри двигается ли текущий оффсет, да из-за одного сообщения кривого вся обработка встаёт если dead letter queue не настроен
да, точно, сори, это можно посмотреть двигается ли оффсет консьюмера. спасибо!! поглядим
Обсуждают сегодня