History

0.1.11 (2023-01-23)

• Fix meta_data bug

0.1.10 (2023-01-23)

• Add Transactional Producer

• Add More Logs for Consumers

• Fix Avro Dependency

0.1.9 (2023-01-03)

• Add consumer_kwargs in consumer

0.1.8 (2022-12-07)

• Add kafka_config in consumer

0.1.7 (2022-11-29)

• Add deserialize key flag

0.1.6 (2022-11-27)

• Add Python 3.10 Support

0.1.5 (2022-06-08)

• Fix AppRegistryNotReady error when importing celery

0.1.4 (2022-06-01)

• Fix group id with prefix in consumer

0.1.3 (2022-05-31)

• Fix auto commit in batch processing.

0.1.1 (2022-05-28)

• Fix value error caused by schema registry invalid configuration.

0.1.0 (2022-05-11)

• First release on PyPI.