uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Revise kafka writer definition

Browse Source
This commit is contained in:
ionutboangiu
2023-02-17 11:12:04 -05:00
committed by Dan Christian Bogos
parent 40943dda09
commit 39d50fd211
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
engine/pstr_kafka.go
View File

@@ -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()
}