**Fixes** - Close kafka consumer at the end of sync - Commit offsets synchronously. - Bump `confluent-kafka[protobuf]` from `2.2.*` to `2.3.*`
8.2.0
------------------ - Add more info logs - Add new config [`debug_contexts`](https://github.com/confluentinc/librdkafka/blob/master/INTRODUCTION.md#debug-contexts) for enabling debugging
8.1.0
------------------ - Bump `dpath` from `2.0.6` to `2.1.*` - Bump `confluent-kafka[protobuf]` from `1.9.2` to `2.2.*` - Bump `grpcio-tools` from `1.51.1` to `1.57.*` - Bump test dependencies
8.0.0
------------------ - Switch from `subscribe` to `assign` for better initial offset control - Implement specifying partitions in configuration
7.1.1
------------------ - Introducing the use of the `seek` method to reset the source partition offsets at the start of a run
7.1.0
------------------ - Bump `pipelinewise-tap-kafka` from confluent-kafka from `1.8.2` to `1.9.0`. - Remove CI checks for Python 3.6