LICENSE
MANIFEST.in
README.md
pyproject.toml
examples/consumer.py
examples/consumer_avro.py
examples/consumer_avro_multiple_subscriptions.py
examples/consumer_confluent.py
examples/factory.py
examples/factory_config.py
examples/factory_consumer.py
examples/producer_avro.py
examples/producer_avro_model.py
examples/producer_avro_model_confluent.py
tests/fixtures/config/answers/enums.py
tests/fixtures/config/answers/fields.py
tests/fixtures/config/answers/models.py
tests/integration/__init__.py
tests/integration/cloudera/__init__.py
tests/integration/cloudera/conftest.py
tests/integration/cloudera/test_deserializing.py
tests/integration/cloudera/test_schema_evolving.py
tests/integration/cloudera/test_serializing_avromodel.py
tests/integration/confluent/__init__.py
tests/integration/confluent/conftest.py
tests/integration/confluent/avro/__init__.py
tests/integration/confluent/avro/test_avro_deserializing.py
tests/integration/confluent/avromodel/__init__.py
tests/integration/confluent/avromodel/test_avromodel_serializing.py
tests/integration/confluent/json/__init__.py
tests/integration/confluent/json/test_json_deserializing.py
tests/integration/confluent/json/test_json_serializing.py
tests/integration/confluent/jsonmodel/__init__.py
tests/integration/confluent/jsonmodel/test_jsonmodel_serializing.py
tests/integration/confluent/mixed/__init__.py
tests/integration/confluent/mixed/test_string_avro_deserializing.py
tests/integration/confluent/mixed/test_string_avromodel_serializing.py
tests/integration/confluent/mixed/test_string_json_deserializing.py
tests/integration/confluent/mixed/test_string_jsonmodel_serializing.py
tests/integration/confluent/string/__init__.py
tests/integration/confluent/string/test_string_string.py
tests/integration/schemaless/__init__.py
tests/integration/schemaless/test_string_json_deserializing.py
tests/integration/schemaless/test_string_jsonmodel_serializing.py
tests/smoke/__init__.py
tests/smoke/conftest.py
tests/smoke/test_callbacks.py
tests/smoke/test_config_krb.py
tests/smoke/test_configs.py
tests/smoke/test_factories.py
tests/unit/__init__.py
tests/unit/test_fs_repo.py
tests/unit/test_generate.py
tests/unit/test_headers.py
tests/unit/test_serialize_shemaless_json.py
tests/unit/test_subscription.py
tests/unit/test_time.py
tests/unit/test_vendors.py
tests/unit/derive/__init__.py
tests/unit/derive/test_avro_base_model.py
tests/unit/derive/test_base_classes.py
tests/unit/derive/test_inheritance.py
tests/unit/derive/test_nested.py
tests/unit/derive/test_topic_naming.py
wunderkafka/__init__.py
wunderkafka/callbacks.py
wunderkafka/compat.py
wunderkafka/errors.py
wunderkafka/librdkafka.py
wunderkafka/logger.py
wunderkafka/protocols.py
wunderkafka/py.typed
wunderkafka/structures.py
wunderkafka/time.py
wunderkafka/types.py
wunderkafka.egg-info/PKG-INFO
wunderkafka.egg-info/SOURCES.txt
wunderkafka.egg-info/dependency_links.txt
wunderkafka.egg-info/requires.txt
wunderkafka.egg-info/top_level.txt
wunderkafka/config/__init__.py
wunderkafka/config/generate.py
wunderkafka/config/rdkafka.py
wunderkafka/config/schema_registry.py
wunderkafka/config/generated/enums.py
wunderkafka/config/generated/fields.py
wunderkafka/config/generated/models.py
wunderkafka/config/generated/_2_0_0/enums.py
wunderkafka/config/generated/_2_0_0/fields.py
wunderkafka/config/generated/_2_0_0/models.py
wunderkafka/config/generated/_2_1_0/enums.py
wunderkafka/config/generated/_2_1_0/fields.py
wunderkafka/config/generated/_2_1_0/models.py
wunderkafka/config/generated/_2_2_0/enums.py
wunderkafka/config/generated/_2_2_0/fields.py
wunderkafka/config/generated/_2_2_0/models.py
wunderkafka/config/generated/_2_3_0/enums.py
wunderkafka/config/generated/_2_3_0/fields.py
wunderkafka/config/generated/_2_3_0/models.py
wunderkafka/config/generated/_2_4_0/enums.py
wunderkafka/config/generated/_2_4_0/fields.py
wunderkafka/config/generated/_2_4_0/models.py
wunderkafka/config/generated/_2_5_0/enums.py
wunderkafka/config/generated/_2_5_0/fields.py
wunderkafka/config/generated/_2_5_0/models.py
wunderkafka/config/generated/_2_6_0/enums.py
wunderkafka/config/generated/_2_6_0/fields.py
wunderkafka/config/generated/_2_6_0/models.py
wunderkafka/config/generated/_2_7_0/enums.py
wunderkafka/config/generated/_2_7_0/fields.py
wunderkafka/config/generated/_2_7_0/models.py
wunderkafka/config/generated/_2_8_0/enums.py
wunderkafka/config/generated/_2_8_0/fields.py
wunderkafka/config/generated/_2_8_0/models.py
wunderkafka/config/krb/__init__.py
wunderkafka/config/krb/rdkafka.py
wunderkafka/config/krb/schema_registry.py
wunderkafka/consumers/__init__.py
wunderkafka/consumers/abc.py
wunderkafka/consumers/bytes.py
wunderkafka/consumers/constructor.py
wunderkafka/consumers/subscription.py
wunderkafka/consumers/types.py
wunderkafka/factories/__init__.py
wunderkafka/factories/avro.py
wunderkafka/factories/json.py
wunderkafka/factories/mixed.py
wunderkafka/factories/schemaless.py
wunderkafka/producers/__init__.py
wunderkafka/producers/abc.py
wunderkafka/producers/bytes.py
wunderkafka/producers/constructor.py
wunderkafka/schema_registry/__init__.py
wunderkafka/schema_registry/abc.py
wunderkafka/schema_registry/cache.py
wunderkafka/schema_registry/transport.py
wunderkafka/schema_registry/clients/__init__.py
wunderkafka/schema_registry/clients/cloudera.py
wunderkafka/schema_registry/clients/confluent.py
wunderkafka/schema_registry/clients/subject.py
wunderkafka/serdes/__init__.py
wunderkafka/serdes/abc.py
wunderkafka/serdes/headers.py
wunderkafka/serdes/protocols.py
wunderkafka/serdes/store.py
wunderkafka/serdes/structures.py
wunderkafka/serdes/vendors.py
wunderkafka/serdes/avro/__init__.py
wunderkafka/serdes/avro/deserializers.py
wunderkafka/serdes/avro/serializers.py
wunderkafka/serdes/avro/types.py
wunderkafka/serdes/avromodel/__init__.py
wunderkafka/serdes/avromodel/pydantic.py
wunderkafka/serdes/avromodel/serializers.py
wunderkafka/serdes/avromodel/derive/__init__.py
wunderkafka/serdes/avromodel/derive/current.py
wunderkafka/serdes/avromodel/typing/__init__.py
wunderkafka/serdes/avromodel/typing/compat.py
wunderkafka/serdes/json/__init__.py
wunderkafka/serdes/json/deserializers.py
wunderkafka/serdes/json/serializers.py
wunderkafka/serdes/jsonmodel/__init__.py
wunderkafka/serdes/jsonmodel/derive.py
wunderkafka/serdes/jsonmodel/serializers.py
wunderkafka/serdes/schemaless/__init__.py
wunderkafka/serdes/schemaless/json/__init__.py
wunderkafka/serdes/schemaless/json/deserializers.py
wunderkafka/serdes/schemaless/json/serializers.py
wunderkafka/serdes/schemaless/jsonmodel/__init__.py
wunderkafka/serdes/schemaless/jsonmodel/serializers.py
wunderkafka/serdes/schemaless/string/__init__.py
wunderkafka/serdes/schemaless/string/deserializers.py
wunderkafka/serdes/schemaless/string/serializers.py
wunderkafka/tests/__init__.py
wunderkafka/tests/consumer.py
wunderkafka/tests/producer.py
wunderkafka/tests/schema_registry.py