LICENSE
MANIFEST.in
README.md
pyproject.toml
django_kafka/__init__.py
django_kafka/apps.py
django_kafka/conf.py
django_kafka/error_handlers.py
django_kafka/exceptions.py
django_kafka/producer.py
django_kafka/py.typed
django_kafka/registry.py
django_kafka/serialization.py
django_kafka/utils.py
django_kafka.egg-info/PKG-INFO
django_kafka.egg-info/SOURCES.txt
django_kafka.egg-info/dependency_links.txt
django_kafka.egg-info/requires.txt
django_kafka.egg-info/top_level.txt
django_kafka/connect/__init__.py
django_kafka/connect/client.py
django_kafka/connect/connector.py
django_kafka/connect/models.py
django_kafka/consumer/__init__.py
django_kafka/consumer/consumer.py
django_kafka/consumer/managers.py
django_kafka/consumer/topics.py
django_kafka/dead_letter/__init__.py
django_kafka/dead_letter/header.py
django_kafka/dead_letter/topic.py
django_kafka/management/__init__.py
django_kafka/management/commands/__init__.py
django_kafka/management/commands/errors.py
django_kafka/management/commands/kafka_connect.py
django_kafka/management/commands/kafka_consume.py
django_kafka/retry/__init__.py
django_kafka/retry/consumer.py
django_kafka/retry/header.py
django_kafka/retry/settings.py
django_kafka/retry/topic.py
django_kafka/tests/__init__.py
django_kafka/tests/models.py
django_kafka/tests/test_django_kafka_interface.py
django_kafka/tests/test_producers.py
django_kafka/tests/test_registry.py
django_kafka/tests/test_settings.py
django_kafka/tests/utils.py
django_kafka/tests/test_connect/__init__.py
django_kafka/tests/test_connect/test_client.py
django_kafka/tests/test_connect/test_connector.py
django_kafka/tests/test_connect/test_kafka_connect_command.py
django_kafka/tests/test_connect/test_models.py
django_kafka/tests/test_connect/test_substitute_error.py
django_kafka/tests/test_consumer/__init__.py
django_kafka/tests/test_consumer/test_consumer.py
django_kafka/tests/test_consumer/test_managers.py
django_kafka/tests/test_consumer/test_topics.py
django_kafka/tests/test_dead_letter/__init__.py
django_kafka/tests/test_dead_letter/test_topic.py
django_kafka/tests/test_retry/__init__.py
django_kafka/tests/test_retry/test_consumer.py
django_kafka/tests/test_retry/test_headers.py
django_kafka/tests/test_retry/test_retry.py
django_kafka/tests/test_retry/test_topic.py
django_kafka/tests/test_topic/__init__.py
django_kafka/tests/test_topic/test_avro.py
django_kafka/tests/test_topic/test_debezium.py
django_kafka/tests/test_topic/test_model.py
django_kafka/tests/test_topic/test_topic.py
django_kafka/tests/test_topic/test_transforms.py
django_kafka/tests/test_utils/__init__.py
django_kafka/tests/test_utils/test_message.py
django_kafka/topic/__init__.py
django_kafka/topic/avro.py
django_kafka/topic/debezium.py
django_kafka/topic/model.py
django_kafka/topic/transforms.py
django_kafka/utils/__init__.py
django_kafka/utils/message.py
django_kafka/utils/retry.py