{"package": "dagster-kafka", "summary": "Enterprise-grade Kafka integration for Dagster with Confluent Connect, comprehensive serialization support, DLQ handling, and production monitoring", "pypi_url": "https://pypi.org/project/dagster-kafka", "piwheels_url": "https://www.piwheels.org/project/dagster-kafka", "releases": {"1.3.1": {"released": "2025-08-21 21:48:42", "prerelease": false, "yanked": false, "skip_reason": "", "files": {"dagster_kafka-1.3.1-py3-none-any.whl": {"file_url": "https://archive1.piwheels.org/simple/dagster-kafka/dagster_kafka-1.3.1-py3-none-any.whl", "filehash": "9f198306f75080780163860e367f7c5a7fb916700d009aee08d0cea0b4d216d1", "filesize": 82974, "builder_abi": "cp311", "file_abi_tag": "none", "platform": "any", "requires_python": ">=3.9", "apt_dependencies": [], "pip_dependencies": ["confluent-kafka", "dagster", "fastavro", "googleapis-common-protos", "grpcio-tools", "jsonschema", "kafka-python", "protobuf", "requests"]}}}, "1.3.0": {"released": "2025-08-21 21:36:46", "prerelease": false, "yanked": false, "skip_reason": "", "files": {"dagster_kafka-1.3.0-py3-none-any.whl": {"file_url": "https://archive1.piwheels.org/simple/dagster-kafka/dagster_kafka-1.3.0-py3-none-any.whl", "filehash": "73ce7f4f2069dce71f14e0999f363006760a8c35f33a7fcdfe4900b292128010", "filesize": 82973, "builder_abi": "cp311", "file_abi_tag": "none", "platform": "any", "requires_python": ">=3.9", "apt_dependencies": [], "pip_dependencies": ["confluent-kafka", "dagster", "fastavro", "googleapis-common-protos", "grpcio-tools", "jsonschema", "kafka-python", "protobuf", "requests"]}}}, "1.2.2": {"released": "2025-08-12 17:41:24", "prerelease": false, "yanked": false, "skip_reason": "", "files": {"dagster_kafka-1.2.2-py3-none-any.whl": {"file_url": "https://archive1.piwheels.org/simple/dagster-kafka/dagster_kafka-1.2.2-py3-none-any.whl", "filehash": "47cc5ec0c12fb25a895cb41af0683d39ecf1ffa16422e4d49524b92cbc353b25", "filesize": 67173, "builder_abi": "cp311", "file_abi_tag": "none", "platform": "any", "requires_python": ">=3.9", "apt_dependencies": [], "pip_dependencies": ["confluent-kafka", "dagster", "fastavro", "googleapis-common-protos", "grpcio-tools", "jsonschema", "kafka-python", "protobuf", "requests"]}}}, "1.2.1": {"released": "2025-08-12 13:46:54", "prerelease": false, "yanked": false, "skip_reason": "", "files": {"dagster_kafka-1.2.1-py3-none-any.whl": {"file_url": "https://archive1.piwheels.org/simple/dagster-kafka/dagster_kafka-1.2.1-py3-none-any.whl", "filehash": "996dc3566fbc22f6f29eef46d30a9c45b7ce6a9890d57656a11d196ab7dbc1cd", "filesize": 67085, "builder_abi": "cp311", "file_abi_tag": "none", "platform": "any", "requires_python": ">=3.9", "apt_dependencies": [], "pip_dependencies": ["confluent-kafka", "dagster", "fastavro", "googleapis-common-protos", "grpcio-tools", "jsonschema", "kafka-python", "protobuf", "requests"]}}}, "1.2.0": {"released": "2025-08-12 13:20:09", "prerelease": false, "yanked": false, "skip_reason": "", "files": {"dagster_kafka-1.2.0-py3-none-any.whl": {"file_url": "https://archive1.piwheels.org/simple/dagster-kafka/dagster_kafka-1.2.0-py3-none-any.whl", "filehash": "a7bec869e4f14303edd16777e9e96fcf61efe85894dac850344af9f6d786ff67", "filesize": 62612, "builder_abi": "cp311", "file_abi_tag": "none", "platform": "any", "requires_python": ">=3.9", "apt_dependencies": [], "pip_dependencies": ["confluent-kafka", "dagster", "fastavro", "googleapis-common-protos", "grpcio-tools", "jsonschema", "kafka-python", "protobuf", "requests"]}}}, "1.1.2": {"released": "2025-07-31 01:07:25", "prerelease": false, "yanked": false, "skip_reason": "", "files": {"dagster_kafka-1.1.2-py3-none-any.whl": {"file_url": "https://archive1.piwheels.org/simple/dagster-kafka/dagster_kafka-1.1.2-py3-none-any.whl", "filehash": "e631d930a6ed6bd1fb49906b85c402f308f72636bd701a0a83b556bebfed3c77", "filesize": 58247, "builder_abi": "cp311", "file_abi_tag": "none", "platform": "any", "requires_python": ">=3.9", "apt_dependencies": [], "pip_dependencies": ["confluent-kafka", "dagster", "fastavro", "googleapis-common-protos", "grpcio-tools", "kafka-python", "protobuf", "requests"]}}}, "1.1.1": {"released": "2025-07-31 00:12:46", "prerelease": false, "yanked": false, "skip_reason": "", "files": {"dagster_kafka-1.1.1-py3-none-any.whl": {"file_url": "https://archive1.piwheels.org/simple/dagster-kafka/dagster_kafka-1.1.1-py3-none-any.whl", "filehash": "5fc4f7a6a86a6dd89bfe90bb35418da81e283e5a3656deeadbb208ab52927b15", "filesize": 58242, "builder_abi": "cp311", "file_abi_tag": "none", "platform": "any", "requires_python": ">=3.9", "apt_dependencies": [], "pip_dependencies": ["confluent-kafka", "dagster", "fastavro", "googleapis-common-protos", "grpcio-tools", "kafka-python", "protobuf", "requests"]}}}, "1.1.0": {"released": "2025-07-29 23:28:14", "prerelease": false, "yanked": false, "skip_reason": "", "files": {"dagster_kafka-1.1.0-py3-none-any.whl": {"file_url": "https://archive1.piwheels.org/simple/dagster-kafka/dagster_kafka-1.1.0-py3-none-any.whl", "filehash": "57237e0a9418e7e5a932ec25f2ceca2d350575723d5b10322f4e201aa62349ed", "filesize": 64107, "builder_abi": "cp311", "file_abi_tag": "none", "platform": "any", "requires_python": ">=3.9", "apt_dependencies": [], "pip_dependencies": ["confluent-kafka", "dagster", "fastavro", "googleapis-common-protos", "grpcio-tools", "kafka-python", "protobuf", "requests"]}}}, "1.0.0": {"released": "2025-07-28 17:34:02", "prerelease": false, "yanked": false, "skip_reason": "", "files": {"dagster_kafka-1.0.0-py3-none-any.whl": {"file_url": "https://archive1.piwheels.org/simple/dagster-kafka/dagster_kafka-1.0.0-py3-none-any.whl", "filehash": "ebd0b2ac6ce4e2d85f36ea3d793909ef325c95f6ce9c948b9a05defa660283fa", "filesize": 60221, "builder_abi": "cp311", "file_abi_tag": "none", "platform": "any", "requires_python": ">=3.9", "apt_dependencies": [], "pip_dependencies": ["confluent-kafka", "dagster", "fastavro", "googleapis-common-protos", "grpcio-tools", "kafka-python", "protobuf", "requests"]}}}}}