From 39d50fd211df8565b8a30f55ca31fae68fe00c64 Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Fri, 17 Feb 2023 11:12:04 -0500 Subject: [PATCH] Revise kafka writer definition --- engine/pstr_kafka.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/engine/pstr_kafka.go b/engine/pstr_kafka.go index a02fe8620..acadad38a 100644 --- a/engine/pstr_kafka.go +++ b/engine/pstr_kafka.go @@ -88,19 +88,19 @@ func (pstr *KafkaPoster) Close() { pstr.Lock() if pstr.writer != nil { pstr.writer.Close() + pstr.writer = nil } - pstr.writer = nil pstr.Unlock() } func (pstr *KafkaPoster) newPostWriter() { pstr.Lock() if pstr.writer == nil { - pstr.writer = kafka.NewWriter(kafka.WriterConfig{ - Brokers: []string{pstr.dialURL}, - MaxAttempts: pstr.attempts, + pstr.writer = &kafka.Writer{ + Addr: kafka.TCP(pstr.dialURL), Topic: pstr.topic, - }) + MaxAttempts: pstr.attempts, + } } pstr.Unlock() }