Consume
[!NOTE]
not done
A reason for using Kafka is the rate of producer exceed the rate of consumer, you want some buffer in the middle to avoid overflowing the consumer.
1 Consumer Group 4 Partitions | 2 Consumer Group 4 Partitions |
---|---|
![]() | ![]() |
4 Consumer Group 4 Partitions | 5 Consumer Group 4 Partitions |
![]() | ![]() |
Multiple Consumer Groups | |
![]() |
- We cant implement fan-out pattern using one consumer group, we need to create multiple of them
- No point adding more consumers than producers, some consumers will be idle.