Let's say I've concurrent level set to 10 and have a topic with 10 partitions and that topic has total of 100 messages on it. Now what I do is, I've a condition that if message type is ABC, only then I proceed with the number addition logic or else I simply ignore the messages with type other than ABC. Assuning ive only one message with type ABC, so whenever the app consumes this message I put the thread to sleep and i intend to wake up that thread to ensure that all messages are consumed by other active threads. So that my sleeping thread can proceed with the addition logic after all messages are processed. If still all messages weren't consumed, then thread again goes to sleep(recursion implemented). But the thing is I don't get any message after a while.. I just get around 97 messages and even if other threads were active they don't read those messages. What can be the reason?