handle kafka connection errors

google · Dec 26, 2024 · fd5e60c · fd5e60c
1 parent 9c239e5
commit fd5e60c
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/internal/tailer/logstream/kafka.go b/internal/tailer/logstream/kafka.go
@@ -96,6 +96,11 @@ func (ks *kafkaStream) stream(ctx context.Context, wg *sync.WaitGroup, oneShot O
 				break
 			}
 
+			if IsExitableError(err) {
+				glog.V(2).Infof("stream(%s): exiting, conn has error %s", ks.sourcename, err)
+				break
+			}
+
 			if err != nil {
 				logErrors.Add(ks.sourcename, 1)
 				glog.V(2).Infof("stream(%s): read error: %v", ks.sourcename, err)