.gitignore
.readthedocs.yaml
Dockerfile
LICENSE
README.rst
docker-compose.yml
pyproject.toml
tox.ini
.github/workflows/tests.yml
django_kafka_streamer.egg-info/PKG-INFO
django_kafka_streamer.egg-info/SOURCES.txt
django_kafka_streamer.egg-info/dependency_links.txt
django_kafka_streamer.egg-info/requires.txt
django_kafka_streamer.egg-info/top_level.txt
docs/Makefile
docs/make.bat
docs/source/commands.rst
docs/source/conf.py
docs/source/configuring.rst
docs/source/index.rst
docs/source/streamers.rst
docs/source/apidoc/celery_tasks.rst
docs/source/apidoc/constants.rst
docs/source/apidoc/decorators.rst
docs/source/apidoc/functions.rst
docs/source/apidoc/index.rst
docs/source/apidoc/streamer.rst
docs/source/apidoc/types.rst
kafkastreamer/__init__.py
kafkastreamer/apps.py
kafkastreamer/constants.py
kafkastreamer/context.py
kafkastreamer/decorators.py
kafkastreamer/funcs.py
kafkastreamer/handlers.py
kafkastreamer/partitioners.py
kafkastreamer/py.typed
kafkastreamer/registry.py
kafkastreamer/serializers.py
kafkastreamer/settings.py
kafkastreamer/squashing.py
kafkastreamer/stream.py
kafkastreamer/tasks.py
kafkastreamer/types.py
kafkastreamer/management/__init__.py
kafkastreamer/management/commands/__init__.py
kafkastreamer/management/commands/kafkastreamer_refresh.py
tests/__init__.py
tests/conftest.py
tests/test_admin_site.py
tests/test_command_refresh.py
tests/test_context.py
tests/test_partitioners.py
tests/test_real_kafka.py
tests/test_registry.py
tests/test_serializers.py
tests/test_squashing.py
tests/test_stream_from_signals.py
tests/test_stream_manual.py
tests/test_streamer.py
tests/test_tasks.py
tests/utils.py
tests/testapp/__init__.py
tests/testapp/admin.py
tests/testapp/models.py
tests/testapp/streamers.py