[GitHub] storm pull request #2465: STORM-2844: KafkaSpout Throws IllegalStateExceptio...

[hmcl]

Github user hmcl commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2465#discussion_r158337077
  
    --- Diff: 
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutEmitTest.java
 ---
    @@ -100,6 +103,8 @@ public void 
testNextTupleEmitsFailedMessagesEvenWhenMaxUncommittedOffsetsIsExcee
                 when(consumerMock.poll(anyLong()))
                     .thenReturn(new ConsumerRecords<>(records));
     
    +            OffsetAndMetadataStub.committed(consumerMock);
    --- End diff --
    
    Done


---