LICENSE.txt
MANIFEST.in
README.md
pyproject.toml
setup.py
src/confluent_kafka/__init__.py
src/confluent_kafka/deserializing_consumer.py
src/confluent_kafka/error.py
src/confluent_kafka/serializing_producer.py
src/confluent_kafka/_model/__init__.py
src/confluent_kafka/_util/__init__.py
src/confluent_kafka/_util/conversion_util.py
src/confluent_kafka/_util/validation_util.py
src/confluent_kafka/admin/__init__.py
src/confluent_kafka/admin/_acl.py
src/confluent_kafka/admin/_cluster.py
src/confluent_kafka/admin/_config.py
src/confluent_kafka/admin/_group.py
src/confluent_kafka/admin/_listoffsets.py
src/confluent_kafka/admin/_metadata.py
src/confluent_kafka/admin/_resource.py
src/confluent_kafka/admin/_scram.py
src/confluent_kafka/admin/_topic.py
src/confluent_kafka/avro/__init__.py
src/confluent_kafka/avro/cached_schema_registry_client.py
src/confluent_kafka/avro/error.py
src/confluent_kafka/avro/load.py
src/confluent_kafka/avro/serializer/__init__.py
src/confluent_kafka/avro/serializer/message_serializer.py
src/confluent_kafka/kafkatest/__init__.py
src/confluent_kafka/kafkatest/verifiable_client.py
src/confluent_kafka/kafkatest/verifiable_consumer.py
src/confluent_kafka/kafkatest/verifiable_producer.py
src/confluent_kafka/schema_registry/__init__.py
src/confluent_kafka/schema_registry/avro.py
src/confluent_kafka/schema_registry/error.py
src/confluent_kafka/schema_registry/json_schema.py
src/confluent_kafka/schema_registry/protobuf.py
src/confluent_kafka/schema_registry/schema_registry_client.py
src/confluent_kafka/serialization/__init__.py
src/confluent_kafka/src/Admin.c
src/confluent_kafka/src/AdminTypes.c
src/confluent_kafka/src/Consumer.c
src/confluent_kafka/src/Metadata.c
src/confluent_kafka/src/Producer.c
src/confluent_kafka/src/confluent_kafka.c
src/confluent_kafka/src/confluent_kafka.h
src/confluent_kafka/superstream/constants.py
src/confluent_kafka/superstream/consumer_interceptor.py
src/confluent_kafka/superstream/core.py
src/confluent_kafka/superstream/exceptions.py
src/confluent_kafka/superstream/factory.py
src/confluent_kafka/superstream/producer_interceptor.py
src/confluent_kafka/superstream/std.py
src/confluent_kafka/superstream/superstream_consumer.py
src/confluent_kafka/superstream/superstream_producer.py
src/confluent_kafka/superstream/types.py
src/confluent_kafka/superstream/update_manager.py
src/confluent_kafka/superstream/utils.py
src/superstream_confluent_kafka.egg-info/PKG-INFO
src/superstream_confluent_kafka.egg-info/SOURCES.txt
src/superstream_confluent_kafka.egg-info/dependency_links.txt
src/superstream_confluent_kafka.egg-info/requires.txt
src/superstream_confluent_kafka.egg-info/top_level.txt
tests/test_Admin.py
tests/test_Consumer.py
tests/test_KafkaError.py
tests/test_Producer.py
tests/test_SerializerError.py
tests/test_TopicPartition.py
tests/test_docs.py
tests/test_enums.py
tests/test_error.py
tests/test_log.py
tests/test_misc.py
tests/test_threads.py