Hi,

It's very likely. Try upgrading your storm-kafka-client dependency and see
if the issue goes away. If not we can look at debugging it.


2017-08-15 20:28 GMT+02:00 pradeep s <[email protected]>:

> Hi,
> I have a storm kafka spout which listens to a group of topics. Max number
> of partitions in a topic is 50. There are 50 spout threads and 7 worker
> nodes.
> Issue is observed when there is a bigger load . All the partitions except
> two or three will be processed .
> When i check kafka manager , same consumer id is stuck for multiple topics
> in that group.
> Is this issue related to https://issues.apache.org/jira/browse/STORM-2343
>
> Thanks
> Pradeep
>

Reply via email to