Expand coverage of idle connection reap message check (#165)

quixio · Jul 31, 2023 · 3c4ff11 · 3c4ff11
1 parent fbf6e06
commit 3c4ff11
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/CsharpClient/QuixStreams.Transport.Kafka/KafkaConsumer.cs b/src/CsharpClient/QuixStreams.Transport.Kafka/KafkaConsumer.cs
@@ -596,7 +596,7 @@ private void OnErrorOccurredHandler(KafkaException exception)
                 return;
             }
 
-            if (exception.Message.Contains("Receive failed: Connection timed out (after "))
+            if (exception.Message.Contains("Receive failed") && exception.Message.Contains("Connection timed out (after "))
             {
                 var match = Constants.ExceptionMsRegex.Match(exception.Message);
                 if (match.Success)