jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(backend): turn on kafka delivery reports

Browse source
This commit is contained in:
Alexander Zavorotynskiy 2022-06-14 10:19:33 +02:00
parent fee99d3bf1
commit 3059227bcd
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
ee/backend/pkg/kafka/producer.go
View file

@ -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,