Offset — порядковый номер сообщения внутри партиции, начиная с 0. Каждый consumer group хранит свой текущий offset для каждой партиции — это позиция, до которой он прочитал. При коммите offset Kafka запоминает: "группа X прочитала партицию Y до позиции Z". Если консюмер упал и перезапустился — продолжит с последнего закоммиченного offset. Можно управлять вручную: сбросить offset в начало (replay всех событий), перемотать вперёд (пропустить проблемные сообщения), или привязать к таймстемпу. Auto-commit удобен, но при падении возможна повторная обработка — нужна идемпотентность.
Что такое offset в Kafka?
Middle
468 просмотровAFK Offer AI
Как сделать self-signed certificate?