Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/2387 Looks like 1.1.x branch also needs the patch, and that branch shouldn't be on top of STORM-2781. https://github.com/apache/storm/blob/1.1.x-branch/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java @hmcl Could you craft a new PR against 1.1.x-branch if my understanding is right? Thanks in advance.
---