консюмер падает, вот с такой ошибкой: {"levelname": "INFO", "name": "kafka.consumer.fetcher", "message": "Fetch offset 2276 is out of range for topic-partition TopicPartition(topic='current_velocities', partition=0)", "asctime": "2021-06-02 09:23:02,042"} гуглинг ничего полезного не дал.. подскажите - как это правильно победить? я консоль консюмером читаю - читается без ошибок
А глянь какое последнее смещение у топика
Выяснилось что консюмер падал из-за оом
ha-ha classic :) Все наверное уже наступали на такое :)
Обсуждают сегодня