Update AsyncIO producer architecture to improve performance#2044

Merged

k-raina merged 42 commits intoasyncfrom

kraina-add-async-sync-comparison

Sep 24, 2025

Commits on Sep 9, 2025

Commits on Sep 10, 2025

Commits on Sep 11, 2025

Commits on Sep 12, 2025

Temp commit to check latency of adding function to threadpool
k-raina
committed

Commits on Sep 15, 2025

Commits on Sep 19, 2025

Per message callbacks should be called for failed messages in batch
k-raina
committed
refactor: extract callback handling into separate AsyncCallbackHandler class
k-raina
committed
refactor: inject AsyncCallbackHandler into CallbackPool for better independence
k-raina
committed
refactor: extract KafkaBatchExecutor for dedicated Kafka operations
k-raina
committed
refactor: eliminate AIOProducer dependency from BatchProcessor for true independence
k-raina
committed
refactor: complete Steps 5-7 - BufferManager, MessageBatch, and clean interfaces
k-raina
committed
refactor: rename BufferManager to BufferTimeoutManager for clarity
k-raina
committed
refactor: organize producer components into dedicated src/aio/producer/ module
k-raina
committed
refactor: merge CallbackPool and AsyncCallbackHandler into unified CallbackManager
k-raina
committed
Cleanup architecture
k-raina
committed
refactor: rename classes for better clarity and consistency
k-raina
committed
Clean meta files
k-raina
committed
cleanup: remove duplicate test files in tests/aio/producer
k-raina
committed
cleanup: remove unrelated test result files and improve gitignore
k-raina
committed

Commits on Sep 23, 2025

Commits on Sep 24, 2025