piwheels

dagster-kafka

Enterprise-grade Kafka integration for Dagster with Confluent Connect, comprehensive serialization support, DLQ handling, and production monitoring

Installation

In a virtualenv (see these instructions if you need to create one):

pip3 install dagster-kafka

Dependencies

• requests
• dagster
• googleapis-common-protos
• fastavro
• kafka-python
• grpcio-tools
• protobuf
• confluent-kafka
• jsonschema

Releases

Version	Released	Bullseye Python 3.9	Bookworm Python 3.11	Trixie Python 3.13	Files
1.3.1	2025-08-21
dagster_kafka-1.3.1-py3-none-any.whl (81 KB)
1.3.0	2025-08-21
dagster_kafka-1.3.0-py3-none-any.whl (81 KB)
1.2.2	2025-08-12
dagster_kafka-1.2.2-py3-none-any.whl (66 KB)
1.2.1	2025-08-12
dagster_kafka-1.2.1-py3-none-any.whl (66 KB)
1.2.0	2025-08-12
dagster_kafka-1.2.0-py3-none-any.whl (61 KB)
1.1.2	2025-07-31
dagster_kafka-1.1.2-py3-none-any.whl (57 KB)
1.1.1	2025-07-31
dagster_kafka-1.1.1-py3-none-any.whl (57 KB)
1.1.0	2025-07-29
dagster_kafka-1.1.0-py3-none-any.whl (63 KB)
1.0.0	2025-07-28
dagster_kafka-1.0.0-py3-none-any.whl (59 KB)

Issues with this package?

• Search issues for this package
• Package or version missing? Open a new issue
• Something else? Open a new issue