Skip to content

Commit 982925c

Browse files
committed
fix: kafka config
1 parent c5a7ed4 commit 982925c

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-
"enable.metrics.push": true,
3635
"enable.idempotence": true,
3736
"linger.ms": kafkaLingerMs,
3837
"go.batch.producer": true, // Enable batch producer (for increased performance).

0 commit comments

Comments
 (0)