Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream tasks will be created and how many will be active?
One partition is assigned a thread, so only 5 will be active, and 25 threads (i.e. tasks) will be created
Currently there are no comments in this discussion, be the first to comment!