RbFly 0.11.0 - a library for RabbitMQ Streams using Python asyncio

[Artur Wroblewski]

I have just released version 0.11.0 of RbFly. It is a library for RabbitMQ
Streams using Python asyncio

https://wrobell.dcmod.org/rbfly/
https://wrobell.dcmod.org/rbfly/changelog.html#ver-0-11-0

RbFly 0.11.0 adds support for TLS authentication using X.509 certificates
and fixes a bug that could prevent applications from quitting properly.
This release supports RabbitMQ 4.2.0 and Python 3.14.

I have updated RbFly performance tests. RabbitMQ 4.2.0 and Kafka 4.1.0 have
been used to compile the current performance report. Kafka uses Raft as
quorum controller instead of Zookeeper during testing.

At minimum, Python 3.12 and RabbitMQ 4.1.0 are required since this release.

The library is designed and implemented with the following qualities in
mind

1. Simple, flexible, and asynchronous Pythonic API with type annotations.
2. Use of AMQP 1.0 message format to enable interoperability between
clients.
3. Performance by implementing critical sections of code using Cython,
avoiding copying of data, and testing.
4. Auto reconnection to RabbitMQ broker with lazily created connection
objects.

RabbitMQ Streams features supported

1. Publishing single messages, or in batches, with confirmation.
2. Subscribing to a stream at a specific point in time, from a specific
offset, or using offset reference.
3. Stream message filtering.
4. Writing stream offset reference.
5. Message deduplication.
6. Integration with AMQP 1.0 ecosystem at message format level.
7. TLS and authentication with X.509 certificates.

Best regards,

Artur

--
https://mortgage.diy-labs.eu/