Bug with Smallrye Kafka integration

[kirankolli-addepar]

Assume that number of consumers are equal to number of partitions. Now if a new consumer joins the group and due to partitions assignment strategy , say that the existing consumer looses the partition and the new consumer gets the partition instead, what is observed is that Smallrye continues to feed to the application the messages that it had polled for before it lost the partition.

This is completely wasteful and not to mention risky. Since the instance has lost the partition, you cannot ack the message as well and processing these polled for messages causes double processing.