forked from gigya/KafkaNetClient
-
Notifications
You must be signed in to change notification settings - Fork 2
Open
Labels
Description
Consumer:
- do not lose message when blocked
- querying should move to the next offset automatically
- cancellation interrupts consumption
- coordinator state changes are managed correctly (when heartbeating, etc)
- when in the middle of processing a message and changing state, resolution for current position is satisfied
Assignment:
- only assigned partitions are read from
- if more members are subscribed than partitions, additional members gracefully exit (and do not cause excessive chatter)
- if same cardinality, one member is assigned to one partition
- if more partitions than members, all partitions are still assigned (as evenly as possible)
- works with 1 or many subscriptions
- extensible to a priority based assignment
Management / monitoring:
- can list topics
- can list consumer groups and offsets
- throughput telemetry numbers lie in correct range