We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 00ee4eb commit fe4aa6dCopy full SHA for fe4aa6d
services/kafka/kafka.go
@@ -62,15 +62,15 @@ func (d *Kafka) Ping() []byte {
62
if d.verbose {
63
d.logger.Println("Kafka error read available brokers")
64
d.logger.Println(err)
65
+ }
66
- // re dial
67
- if strings.Contains(err.Error(), ErrorClosedNetwork) {
+ // re dial
68
+ if strings.Contains(err.Error(), ErrorClosedNetwork) {
69
+ d.logger.Println(fmt.Sprintf("Kafka: %s | do re dial\n", err.Error()))
70
+ // re dial ignore error
71
+ err = d.dial()
72
+ if err != nil {
73
d.logger.Println(fmt.Sprintf("Kafka: %s | do re dial\n", err.Error()))
- // re dial ignore error
- err = d.dial()
- if err != nil {
- d.logger.Println(fmt.Sprintf("Kafka: %s | do re dial\n", err.Error()))
- }
74
}
75
76
return []byte("NOT_OK")
0 commit comments