Hi All,

We are facing an issue with our kafka streams application due to uneven
task allocation. There are 100 partitions in the input topic with 100
stream threads processing the data. Everything works well when each task
gets assigned with 1 partition. But when more than one partition is
assigned to the same thread then it causes delay in processing causing a
huge backlog.

How is everyone handling this? This creates a huge impact to the
application SLA and we would like to minimize such cases. Any suggestions
would be appreciated.

Note: we are on version 2.6.2

Thanks,
Navneeth

Reply via email to