VOL-2348 I/O Errors should trigger unreadiness
Change-Id: I11383f3de7895ca44b6cfc6b6686dcf703467e79
diff --git a/pkg/kafka/sarama_client.go b/pkg/kafka/sarama_client.go
index ca88dfd..c05df69 100755
--- a/pkg/kafka/sarama_client.go
+++ b/pkg/kafka/sarama_client.go
@@ -532,6 +532,11 @@
return true
}
+ if strings.HasSuffix(err.Error(), "i/o timeout") { // "dial tcp 10.244.1.176:9092: i/o timeout"
+ log.Info("is-liveness-error-io-timeout")
+ return true
+ }
+
// Other errors shouldn't trigger a loss of liveness
log.Infow("is-liveness-error-ignored", log.Fields{"err": err})