7 месяцев назад
Гарантии доставки в Kafka. Как не терять сообщения
ACK (acknowledgment) — подтверждение от Kafka брокера, что сообщение успешно получено и записано. Kafka поддерживает 3 уровня подтверждения: 0 - Продюсер не ждёт подтверждения (возможна потеря сообщений). 1 - Брокер-лидер партиции подтверждает получение. all / -1 - Сообщение считается принятым, когда все ISR (in-sync replicas) подтвердят запись. Это наиболее надежный вариант. goКопироватьРедактироватьw := kafka.NewWriter(kafka.WriterConfig{ Brokers: []string{"localhost:9092"}, Topic: "example-topic", RequiredAcks: kafka...