Repository navigation

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

Commits on Oct 5, 2026
- feat(kafka): Add AsyncKafkaConsumer with per-partition async queues
  lvthanh03
  committed
  749aee7
Commits on Oct 6, 2026
- explicit shutdown path
  lvthanh03
  committed
  83f1bf0
- respect consumer offset config and expose manual commits
  lvthanh03
  committed
  c218323