В Kafka факт прочтения сообщения определяется с помощью смещений (offsets) в партициях топика. Каждый потребитель (consumer) отслеживает, до какого смещения он прочитал сообщения в каждой партиции.

Чтобы определить, что сообщение прочитано, нужно:

Убедиться, что потребитель успешно обработал сообщение.
Зафиксировать (commit) смещение этого сообщения в Kafka, то есть сообщить брокеру, что все сообщения до этого смещения обработаны.

В Go, используя клиент Kafka (например, sarama или confluent-kafka-go), можно явно коммитить смещения после обработки сообщений. Если смещение закоммичено, значит сообщение считается прочитанным и не будет доставлено повторно этому потребителю.

Пример с sarama (упрощённо):

consumer.MarkMessage(msg, "") // Отметить сообщение как прочитанное
consumer.CommitOffsets()       // Зафиксировать смещения

Таким образом, факт прочтения — это успешный коммит смещения в Kafka.

Каким образом можно определить факт прочтения сообщения в Kafka?