Основное различие между session.MarkMessage и session.MarkOffset в библиотеке Sarama...
продолжить чтение
Потребитель в группе может читать сообщения из нескольких разделов одновременно. Как именно распределяются разделы между потребителями зависит от следующих факторов:...
продолжить чтение
В Kafka при использовании потребителя нужно явно помечать сообщения как обработанные (committed). Это называется фиксацией смещения (offset commit). В контексте пакетной обработки сообщений это можно делать одним из двух способов:...
продолжить чтение
config.Consumer.Offsets.AutoCommit.Enable = true
config.Consumer.Offsets.AutoCommit.Interval = 10 * 1000 ...
продолжить чтение