feat: Improve kafka backpreassure - #410

Merged

CarlosGamero merged 26 commits into

mainfrom

feat/improve_kafka_backpreassure

Feb 28, 2026

Commits on Jan 21, 2026

Back to duplex
CarlosGamero
committed
ea6bb3a
Proper backpreassure handling on batch stream
CarlosGamero
committed
a633009
Improving tests
CarlosGamero
committed
1b967fa
lint
CarlosGamero
committed
8fed538
Ajusting consumer
CarlosGamero
committed
6b516d4

Commits on Feb 19, 2026

Improving logging
CarlosGamero
committed
13aaacb

Commits on Feb 26, 2026

Merge branch 'main' into feat/improve_kafka_backpreassure
CarlosGamero
committed
f54213e
erro handling
CarlosGamero
committed
37b9574
Update kafka lib
CarlosGamero
committed
f3b2848
Remove maxWait from test
CarlosGamero
committed
094ad19
Lint fix
CarlosGamero
committed
1814df8
Revert "Remove maxWait from test"
CarlosGamero
committed
f2adcea
Coverage fix
CarlosGamero
committed
36dbdb5
Handling backpreassure on timeout + tests
CarlosGamero
committed
719d19f

Commits on Feb 27, 2026

Typo fix
CarlosGamero
committed
3e19de7
New readableHighWaterMark param
CarlosGamero
committed
6d733b2
Adding test
CarlosGamero
committed
9e81bc1
Addressing final comment
CarlosGamero
committed
87e8a1c
AI comments
CarlosGamero
committed
fb7e355
Error handling
CarlosGamero
committed
876f49a
Minor change
CarlosGamero
committed
983424f
Merge branch 'main' of https://github.com/kibertoad/message-queue-toolkit into feat/improve_kafka_backpreassure
kibertoad
committed
041eefd
Merge branch 'main' into feat/improve_kafka_backpreassure
CarlosGamero
committed
8b76727
typo
CarlosGamero
committed
b68c633

Commits on Feb 28, 2026