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

Set kafka MaxAttempts to 1

Browse Source 
This leaves it to the ExportWithAttempts function to handle the
connect attempts.
This commit is contained in:
ionutboangiu
2024-04-10 17:19:10 +03:00
committed by Dan Christian Bogos
parent e025a0dc89
commit 88b02a3249
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
ees/kafka.go
View File

@@ -76,9 +76,12 @@ func (pstr *KafkaEE) Connect() (_ error) {
defer pstr.Unlock()
if pstr.writer == nil {
pstr.writer = &kafka.Writer{
Addr: kafka.TCP(pstr.Cfg().ExportPath),
Topic: pstr.topic,
MaxAttempts: pstr.Cfg().Attempts,
Addr: kafka.TCP(pstr.Cfg().ExportPath),
Topic: pstr.topic,
// Leave it to the ExportWithAttempts function
// to handle the connect attempts.
MaxAttempts: 1,
}
}
if pstr.tls {