- Fix meta_data bug
- Add Transactional Producer
- Add More Logs for Consumers
- Fix Avro Dependency
- Add consumer_kwargs in consumer
- Add kafka_config in consumer
- Add deserialize key flag
- Add Python 3.10 Support
- Fix AppRegistryNotReady error when importing celery
- Fix group id with prefix in consumer
- Fix auto commit in batch processing.
- Fix value error caused by schema registry invalid configuration.
- First release on PyPI.