Kafka mimarisinde mesaj teslim onay verilerinin genellikle nerede saklandığını?
sobes.tech yapay zeka
AI'dan gelen yanıt
В архитектуре Apache Kafka данные о подтверждении доставки сообщений (offsets) обычно сохраняются в специальной внутренней теме Kafka под названием __consumer_offsets.
Когда потребитель (consumer) обрабатывает сообщения из топика, он периодически фиксирует (commits) смещение (offset) последнего обработанного сообщения. Эти смещения сохраняются в __consumer_offsets, что позволяет при перезапуске или сбое продолжить чтение с нужного места.
Таким образом, подтверждения доставки не хранятся в приложении, а централизованно в Kafka, обеспечивая надежность и масштабируемость.
Пример фиксации offset в Go с использованием библиотеки sarama:
consumer.MarkOffset(message, "")
Это сообщает Kafka, что сообщение обработано, и offset сохранится в __consumer_offsets.