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