From 30bef015b6d38d686bf5266c5177731c69c78a33 Mon Sep 17 00:00:00 2001
From: Warren Falk <wfalk@divisionsinc.com>
Date: Fri, 1 May 2015 15:51:04 -0400
Subject: [PATCH] correctly handle consumer maxwait timeouts over 31 bits in
 milliseconds

---
 src/kafka-net/Consumer.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/kafka-net/Consumer.cs b/src/kafka-net/Consumer.cs
index 4f5514ab..99b9afcb 100644
--- a/src/kafka-net/Consumer.cs
+++ b/src/kafka-net/Consumer.cs
@@ -140,7 +140,7 @@ private Task ConsumeTopicPartitionAsync(string topic, int partitionId)
 
                             var fetchRequest = new FetchRequest
                                 {
-                                    MaxWaitTime = (int)_options.MaxWaitTimeForMinimumBytes.TotalMilliseconds,
+                                    MaxWaitTime = (int)Math.Min((long)int.MaxValue, _options.MaxWaitTimeForMinimumBytes.TotalMilliseconds),
                                     MinBytes = _options.MinimumBytes,
                                     Fetches = fetches
                                 };