From 3059227bcde81ca1c247ebb57178770771a97bce Mon Sep 17 00:00:00 2001 From: Alexander Zavorotynskiy Date: Tue, 14 Jun 2022 10:19:33 +0200 Subject: [PATCH] feat(backend): turn on kafka delivery reports --- ee/backend/pkg/kafka/producer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ee/backend/pkg/kafka/producer.go b/ee/backend/pkg/kafka/producer.go index 7f59d971f..db98a650a 100644 --- a/ee/backend/pkg/kafka/producer.go +++ b/ee/backend/pkg/kafka/producer.go @@ -20,7 +20,7 @@ func NewProducer() *Producer { producer, err := kafka.NewProducer(&kafka.ConfigMap{ "enable.idempotence": true, // TODO: get rid of "bootstrap.servers": env.String("KAFKA_SERVERS"), - "go.delivery.reports": false, + "go.delivery.reports": true, "security.protocol": protocol, "go.batch.producer": true, "queue.buffering.max.ms": 100,