feat: asynchronous message publishing with batching and pre-commit delivery guarantees (Enterprise) - #684

Merged

dgafka merged 38 commits into

mainfrom

async-publishing

Aug 4, 2026

Commits on Jul 3, 2026

refactor: message collector releases messages as BatchMessage per channel
dgafka
committed
473825a
feat: MessagePublisher asyncPublish returning Future with pending delivery tracking
dgafka
committed
e1b7331
feat: asyncPublish accepts BatchMessage for whole-batch delivery
dgafka
committed
69f9488
feat: async publishing channels awaited via interceptor before transaction commits
dgafka
committed
9af6f73
test: async publishing collector on/off matrix coverage
dgafka
committed
f15f738
feat: error channel routing and transaction semantics for async publishing
dgafka
committed
e3da996
feat: Kafka async publishing with delivery reports and deferred flush
dgafka
committed
3459b7a
feat: AMQP async publishing with batched publisher confirms
dgafka
committed
edcf893
feat: CI benchmark comparing synchronous and async publishing for AMQP and Kafka
dgafka
committed
aa10185
feat: asyncPublish gateway for Kafka and AMQP MessagePublishers, Kafka TCP_NODELAY default
dgafka
committed
6689f2c
feat: AMQP frame batching publishes BatchMessage in single socket write
dgafka
committed
f60e678
perf: amortized registry pruning and MessagePublisher-based publishing benchmark
dgafka
committed
b02e2b3
test: async publishing without enterprise licence fails for channels and publishers
dgafka
committed
e139dce
fix: reliability hardening for async publishing based on review findings
dgafka
committed
800ab62
test: failure-proving reliability tests for async publishing
dgafka
committed
d775623
feat: batch and asyncPublish support for DBAL backed channels and publishers
dgafka
committed
36fd629
feat: batch and asyncPublish support for Redis backed channels and publishers
dgafka
committed
cd9d88f
feat: batch and promise-based async publishing for SQS backed channels and publishers
dgafka
committed
9c45c22
refactor: share single and batch send flow in enqueue provider adapters
dgafka
committed
7e59e0f
feat: benchmark single/batch sync/async publishing matrix for all providers
dgafka
committed
198c550
perf: bound SQS async publishing concurrency via lazy request dispatching
dgafka
committed
f5c2923
fix: close silent-loss paths across async publishing providers
dgafka
committed
4e88568

Commits on Jul 13, 2026

Commits on Jul 14, 2026

Commits on Jul 18, 2026

Commits on Aug 3, 2026

Commits on Aug 4, 2026

test: give kafka deduplication consumer runs realistic time budget matching existing in-file pattern
dgafka
committed
f0da42e