Something went wrong. Try again.
lol
Something went wrong. Try again.
2.7 kB · 126 lines
Nix
at master
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127{ lib, attrs, authlib, avro, azure-identity, azure-keyvault-keys, boto3, buildPythonPackage, cachetools, fastavro, fetchFromGitHub, google-auth, google-api-core, google-cloud-kms, hvac, httpx, jsonschema, orjson, protobuf, pyflakes, pyrsistent, pytest-asyncio, pytestCheckHook, pyyaml, rdkafka, requests, requests-mock, respx, setuptools,}:
buildPythonPackage rec { pname = "confluent-kafka"; version = "2.13.0"; pyproject = true;
src = fetchFromGitHub { owner = "confluentinc"; repo = "confluent-kafka-python"; tag = "v${version}"; hash = "sha256-VnZf6YvvpOs9/9uJHJvcmF56Ra9hhsoqrVisDuf+C6w="; };
buildInputs = [ rdkafka ];
build-system = [ setuptools ];
optional-dependencies = { avro = [ avro fastavro requests ]; json = [ jsonschema pyrsistent requests ]; protobuf = [ protobuf requests ]; rules = [ azure-identity azure-keyvault-keys boto3 # TODO: cel-python google-auth google-api-core google-cloud-kms # hkdf was removed hvac # TODO: jsonata-python pyyaml # TODO: tink ]; schema-registry = [ attrs authlib cachetools httpx orjson ]; };
nativeCheckInputs = [ cachetools orjson pyflakes pytest-asyncio pytestCheckHook requests-mock respx ] ++ lib.concatAttrValues optional-dependencies;
pythonImportsCheck = [ "confluent_kafka" ];
disabledTestPaths = [ "tests/integration/" "tests/test_Admin.py" "tests/test_misc.py" # Failed: async def functions are not natively supported. "tests/schema_registry/_async" # missing cel-python dependency "tests/schema_registry/_sync/test_avro_serdes.py" "tests/schema_registry/_sync/test_json_serdes.py" "tests/schema_registry/_sync/test_proto_serdes.py" # missing tink dependency "tests/schema_registry/_async/test_config.py" "tests/schema_registry/_sync/test_config.py" # crashes the test runner on shutdown "tests/test_kafka_error.py" # stats_cb can raise during consumer.close() causing race-condition "tests/test_Consumer.py::test_callback_exception_no_system_error" ];
meta = { description = "Confluent's Apache Kafka client for Python"; homepage = "https://github.com/confluentinc/confluent-kafka-python"; changelog = "https://github.com/confluentinc/confluent-kafka-python/blob/${src.tag}/CHANGELOG.md"; license = lib.licenses.asl20; maintainers = with lib.maintainers; [ mlieberman85 ]; };}