- Added entrypoint for consuming Kafka messages
- Added dependency provider for publishing Kafka messages
- Added code coverage for the extension
- Fixed identifier of managed spawned thread in entrypoint
- Added support different commit strategies
- Added MongoDB offset storage for exactly once delivery semantics
- Removed wrapt dependency
- Fixed nameko and kafka-python version