- use poetry to publish packages
- update confluent-kafka-python to version 1.6.1
- Use DeserializingConsumer instead of deprecated AvroConsumer and SerializingProducer instead of AvroProducer
- remove RichAvroConsumer
- replace pipenv with poetry
- use docker-compose for tests
- Enabled the Sink to retry committing offsets in case of failure. The maximum number of retries is configurable through
the
sink_commit_retry_count
field.
- Enable JSON logging using loguru
- Fix bug fix introduced in Version 0.4.2, only commit offsets if exist.
- Make consumer offset commits synchronous.
- Introduce hashing of sensitive values.