Pyconnect Version 0.5.1

Breaking changes

• update confluent-kafka-python to version 1.6.1
• Use DeserializingConsumer instead of deprecated AvroConsumer and SerializingProducer instead of AvroProducer
• remove RichAvroConsumer

Other changes

• replace pipenv with poetry
• use docker-compose for tests
• use poetry to publish packages

Added a retry option for Sink

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.

Pyconnect Version 0.4.4

Enable JSON logging using loguru

Pyconnect Version 0.4.3

Fix bug caused by synchronous committing of empty offsets variable.

Pyconnect Version 0.4.2

Make consumer offset commits synchronous.

Pyconnect Version 0.4.1

Version 0.4.1

• Add PYCONNECT_HASH_SENSITIVE_VALUES to specify if sensitive values should get logged as a hash or totally hidden.