TP-5555 | no pod restart if kafka topic is not available

2024-10-25 06:43:47 +05:30
parent 6f16c620a9
commit 1bf80ee849
1 changed files with 1 additions and 1 deletions
--- a/pkg/kafka/consumer/consume.go
+++ b/pkg/kafka/consumer/consume.go
@@ -47,7 +47,7 @@ func (consumer *Consumer) AttachErrorListener() {

 	if err != nil {
 		fmt.Fprintf(os.Stderr, "Failed to subscribe to topics: %s\n", err)
-		os.Exit(1)
+		return
 	}
 	run := true
 	sigchan := make(chan os.Signal, 1)