Marcos Schroh

feat: rebalance listener added to Consumer constructor

5

### Changes Fixes https://github.com/aio-libs/aiokafka/issues/842 * Now it is possible to set the `ConsumerRebalanceListener` when a `Consumer` instance is created. * The validation is made in the `SubscriptionState._validate_rebalance_listener` method. * The...

Hi, Thanks for the work that you are doing!! According to the code, the only way to use the `ConsumerRebalanceListener` is using the `subscribe` method, I was wondering: Why is...

Rename serializer methods

6

decode_message --> deserialize encode_record_with_schema_id --> serialize. Potentially, only 1 serialization method should be available that could receive either a schema_id or a Schema object.

Create Event class to use with the serializer.

1

When `encode_record_with_schema_id` or `encode_record_with_schema` is called with `data/record`, these methods should return an `Event object` containing the `data/record`, the `payload` (the data encoded), the `schema_id` used to serialize the data...

*Goal*: Perform auto bumping and auto deployment after a PR is merged into master. *Description*: Add commitizen as a dependency of the root project. When a PR is merged into...

We want a command for create a `faust app` (new python package). The idea is similar to what `Django` does when the command `python manage.py startapp polls`. In this case...

Docker compose added with `Zookeeper, Kafka and Schema registry`. `Faust` image updated.