Skip to content

Commit c5a7ed4

Browse files
committed
fix: kafka config
1 parent e8f1f24 commit c5a7ed4

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

main.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@ func main() {
3232
"compression.codec": kafkaCompression,
3333
"batch.num.messages": kafkaBatchNumMessages,
3434
"queue.buffering.max.messages": kafkaBatchNumMessages,
35-
"delivery.report.only.error": true,
3635
"enable.metrics.push": true,
3736
"enable.idempotence": true,
3837
"linger.ms": kafkaLingerMs,

0 commit comments

Comments
 (0)