From a5d333954cade20fe2ee3345e1c27c29528d72e6 Mon Sep 17 00:00:00 2001
From: pczb <pczb@163.com>
Date: Sat, 19 Aug 2017 12:01:46 +0800
Subject: [PATCH] fix not poll bug when use manual commit

---
 .../src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
index e4b53ab9feb..a036b8f2958 100644
--- a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
+++ b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
@@ -267,7 +267,7 @@ private boolean poll() {
             //Accounting for retriable tuples this way still guarantees that the limit is followed on a per partition basis,
             //and prevents locking up the spout when there are too many retriable tuples
             && (numUncommittedOffsets - readyMessageCount < maxUncommittedOffsets
-            || consumerAutoCommitMode);
+            || consumerAutoCommitMode || readyMessageCount >= maxUncommittedOffsets);
         
         if (!poll) {
             if (waitingToEmit()) {