CCDAK · Question #178
A stream processing application is consuming from a topic with five partitions. You run three instances of the application. Each instance has num.streams.threads set to five. You need to identify…
The correct answer is C. 15 created, 5 actively consuming. With three instances and num.streams.threads set to five, a total of 15 stream tasks are created (3 instances × 5 threads each). However, only five tasks will actively consume messages from the five partitions, since there are only five partitions to assign.
Question
A stream processing application is consuming from a topic with five partitions. You run three instances of the application. Each instance has num.streams.threads set to five. You need to identify the number of stream tasks that will be created and how many will actively consume messages from the input topic. Which option is correct?
Options
- A5 created, 1 actively consuming
- B5 created, 5 actively consuming
- C15 created, 5 actively consuming
- D15 created, 15 actively consuming
How the community answered
(35 responses)- A14% (5)
- B9% (3)
- C51% (18)
- D26% (9)
Explanation
With three instances and num.streams.threads set to five, a total of 15 stream tasks are created (3 instances × 5 threads each). However, only five tasks will actively consume messages from the five partitions, since there are only five partitions to assign.
Topics
Community Discussion
No community discussion yet for this question.