Skip to content

feat(kafka): Add AsyncKafkaConsumer with per-partition async queues - #579

Merged
lvthanh03 merged 3 commits into
mainfrom
tony/async-consumer
Oct 6, 2026
Merged

feat(kafka): Add AsyncKafkaConsumer with per-partition async queues#579
lvthanh03 merged 3 commits into
mainfrom
tony/async-consumer

respect consumer offset config and expose manual commits

c218323
Select commit
Loading
Failed to load commit list.

Select a check to view from the sidebar