| Index | index by Group | index by Distribution | index by Vendor | index by creation date | index by Name | Mirrors | Help | Search |
| Name: python314-confluent-kafka | Distribution: openSUSE Tumbleweed |
| Version: 2.14.0 | Vendor: openSUSE |
| Release: 1.1 | Build date: Sat Apr 11 14:10:40 2026 |
| Group: Development/Languages/Python | Build host: reproducible |
| Size: 2983513 | Source RPM: python-confluent-kafka-2.14.0-1.1.src.rpm |
| Packager: https://bugs.opensuse.org | |
| Url: https://github.com/confluentinc/confluent-kafka-python | |
| Summary: Confluent's Apache Kafka client for Python | |
Confluent's Apache Kafka client for Python
Apache-2.0
* Sat Apr 11 2026 Dirk Müller <dmueller@suse.com>
- update to 2.14.0:
* Implement async context manager protocol for AIOProducer and
AIOConsumer
* Add AssociatedNameStrategy
* Add enableAt to RuleSet
* Ensure normalize.schemas config is passed during Protobuf ref
lookup #2214
* Fix type annotations for context manager hooks so that they
are correct for subclasses
* Fix OAuth callback handling for Async IO clients to prevent
initialization failures
* confluent-kafka-python v2.14.0 is based on librdkafka
v2.14.0, see the
* librdkafka release notes
* for a complete list of changes, enhancements, fixes and
upgrade considerations.
- update to 2.13.2:
* v2.13.2 is a maintenance release with the following fixes and
enhancements:
* Add Confluent-Client-Version header to requests to SR, Python
client
* Add UAMI OAuth changes
* Fixed memory leak in Producer.produce() when called with
headers and raises BufferError (queue full) or RuntimeError
(producer closed). The allocated rd_headers memory is now
properly freed in error paths before returning. Fixes Issue
https://github.com/confluentinc/confluent-kafka-
python/issues/2167.
* Fixed type hinting of KafkaError class, Consumer.__init()__,
Producer.__init()__, Producer.produce() and Consumer.commit()
and introduced a script in tools directory to keep error
codes up to date. Fixes Issue
https://github.com/confluentinc/confluent-kafka-
python/issues/2168.
* Fix the token expiration logic in SR Oauth
* Ensure use of cachetools is thread-safe
* Remove passing resolver in json validate
- update to 2.13.0:
* Enforced type hinting for all interfaces
* Handle OAuth Token Refreshes using background thread for
Admin, Producer and Consumer clients
* Added black and isort linting rules and enforcement to
codebase
* Enabled direct creation of Message objects
* Added `close()` method to producer
* Added context manager for librdkafka classes to enable easy
scope cleanup
* Expose deterministic partitioner functions
* Add Accept-Version header for schemas
* Enhanced the BufferTimeoutManager to flush the librdkafka
queue
* Remove experimental module designation for Async classes
* Add `__len__` function to AIOProducer
* Enhance Message class to include serialisation support and
rich comparison
* Support Strict Validation Flags in Avro Serializers
* Type hint `__enter__` to return the same object type that
called it
* Fixed `Consumer.poll()`, `Consumer.consume()`,
`Producer.poll()`, and `Producer.flush()` blocking
indefinitely and not responding to Ctrl+C (KeyboardInterrupt)
signals. The implementation now uses a "wakeable poll"
pattern that breaks long blocking calls into smaller chunks
(200ms) and periodically re-acquires the Python GIL to check
for pending signals. This allows Ctrl+C to properly interrupt
blocking operations. Fixes Issues #209 and #807 (#2126).
* Fix support for wrapped Avro unions
* Fixed segfault exceptions on calls against objects that had
closed internal objects
* Handle evolution during field transformation of schemas
* Handle null group name to prevent segfault in Admin
`list_consumer_group_offsets()`
* Ensure schemaId initialization is thread-safe
* Fix error propagation rule for Python's C API
* Fix SR delete behavior with client-side caching
* Don't leave NewTopic partially-initialized on error
* Fix formatting issue of TopicPartition that causes
SystemError on Windows
* Add Py_None check for msg and offset params in `commit()` and
`store_offsets()`
* Fix experimental module references
* Update outdated example in README.md
* Fri Apr 03 2026 Dirk Müller <dmueller@suse.com>
- update to 2.12.1:
* Restored macOS binaries compatibility with macOS 13
* `libversion()` now returns the string/integer tuple for
varients on version -- use `version()` for string only
response
* Added Python 3.14 support and dropped 3.7 support -- Free-
threaded capabilities not fully supported yet
* Fixed use.schema.id in `sr.lookup_schema()`
* Removed tomli dependency from standard (non-documentation)
requirements
* Fixed experimental asyncio example files to correctly use new
capabilities
* Fixed invalid argument error on schema lookups on repeat
requests
* Fixed documentation generation and added error checks for
builds to prevent future breaks
- update to 2.12.0:
* Starting with __confluent-kafka-python 2.12.0__, the next
generation consumer group rebalance protocol defined in
* *KIP-848** is **production-ready**. Please refer to the
following migration guide for moving from `classic` to
`consumer` protocol.
* **Note:** The new consumer group protocol defined in KIP-848
is not enabled by default. There are few contract change
associated with the new protocol and might cause breaking
changes. `group.protocol` configuration property dictates
whether to use the new `consumer` protocol or older `classic`
protocol. It defaults to `classic` if not provided.
* ### AsyncIO Producer (experimental)
* Introduces beta class `AIOProducer` for asynchronous message
production in asyncio applications.
* AsyncIO Producer (experimental): Introduces beta class
`AIOProducer` for
* asynchronous message production in asyncio applications. This
API offloads
* blocking librdkafka calls to a thread pool and schedules
common callbacks
* (`error_cb`, `throttle_cb`, `stats_cb`, `oauth_cb`, `logger`)
onto the event
* loop for safe usage inside async frameworks.
* #### Features
* Batched async produce: `await AIOProducer(...).produce(topic,
value=...)`
* buffers messages and flushes when the buffer threshold or
timeout is reached.
* Async lifecycle: `await producer.flush()`, `await
producer.purge()`, and
* transactional operations (`init_transactions`,
`begin_transaction`,
* `commit_transaction`, `abort_transaction`).
- update to 2.10.1:
* Handled `None` value for optional `ctx` parameter in
`ProtobufDeserializer`
* Handled `None` value for optional `ctx` parameter in
`AvroDeserializer`
- update to 2.10.0:
* [KIP-848] Group Config is now supported in AlterConfigs,
IncrementalAlterConfigs and DescribeConfigs.
* [KIP-848] `describe_consumer_groups()` now supports KIP-848
introduced `consumer` groups. Two new fields for consumer
group type and target assignment have also been added. Type
defines whether this group is a `classic` or `consumer`
group. Target assignment is only valid for the `consumer`
protocol and its defaults to NULL. (#1873).
* Fri Jul 18 2025 Dirk Müller <dmueller@suse.com>
- update to 2.8.0:
* Ensure algorithm query param is passed for CSFLE
* DGS-19492 Handle records nested in arrays/maps when searching
for tags
* confluent-kafka-python v2.8.0 is based on librdkafka v2.8.0,
see the librdkafka release notes
- update to 2.7.0:
* Support for Data Contracts with Schema Registry, including
+ Data Quality rules
+ Data Transformation rules
+ Client-Side Field Level Encryption (CSFLE)
+ Schema Migration rules (requires Python 3.9+)
* Migrated the Schema Registry client from requests to httpx
* Add support for multiple URLs
* Allow configuring timeout
* Fix deletion semantics
* Python deserializer can take SR client
* Fix handling of Avro unions
* Remove deprecated RefResolver for JSON
* Support delete of subject version
* Added missing dependency on googleapis-common-protos when
using protobufs.
- update to 2.6.2:
* Support for Data Contracts with Schema Registry, including
* Data Quality rules
* Data Transformation rules
* Client-Side Field Level Encryption (CSFLE)
* Schema Migration rules (requires Python 3.9+)
* Migrated the Schema Registry client from requests to httpx
* Add support for multiple URLs
* Allow configuring timeout
* Fix deletion semantics
* Python deserializer can take SR client
* Fix handling of Avro unions
* Remove deprecated RefResolver for JSON
* Support delete of subject version
* Added Python 3.13 wheels (#1828).
* KIP-460 Admin Leader Election RPC
* Added Transactional id resource type for ACL operations
- update to 2.5.3:
* Fix an assert being triggered during push telemetry call when
no metrics matched on the client side.
* Minor enhancement to JSONDeserializer to retrieve schema from
Schema Registry if not provided
* confluent-kafka-python is based on librdkafka v2.5.3, see the
* librdkafka release notes
* for a complete list of changes, enhancements, fixes and
upgrade considerations.
- update to 2.5.0:
* KIP-107 Added delete_records API.
* Added an example to show the usage of the custom logger with
`AdminClient`.
* Improve caching on Schema Registry client.
* Removed usage of `strcpy` to enhance security of the client.
* Removed support for centos6 and centos7.
* Fixed invalid write in `OAUTHBEARER/OIDC` extensions copy.
* Fixed documentation for default value of `operation_timeout`
and `request_timeout` in various Admin apis.
* Fixed an issue related to import error of `TopicCollection`
and `TopicPartitionInfo` classes when importing through other
module like mypy.
* Fixed a segfault when `commit` or `store_offsets` consumer
method is called incorrectly with errored Message object.
* Fixed `logger` not working when provided as an argument to
`AdminClient` instead of a configuration property.
* Fixed some memory leaks related to `PyDict_SetItem`.
- update to 2.4.0:
* KIP-848: Added KIP-848 based new consumer group rebalance
protocol. The feature is an **Early Access**: not production
ready yet. Please refer detailed doc for more information.
* Fix segfault with describe_topics and flaky connection
(@lpsinger, #1692)
* Fri May 23 2025 Markéta Machová <mmachova@suse.com>
- Convert to pip-based build
* Sat Dec 02 2023 Dirk Müller <dmueller@suse.com>
- update to 2.3.0:
* Add Python 3.12 wheels
* KIP-117: Add support for AdminAPI `describe_cluster()` and
`describe_topics()`. (@jainruchir, #1635)
* KIP-430:
* Return authorized operations in Describe Responses.
(@jainruchir, #1635)
* KIP-516: Partial support of topic identifiers. Topic
identifiers in metadata response are available through the
new describe_topics function (#1645).
* KIP-396: completed the implementation with the addition of
`list_offsets` (#1576).
* Add `Rack` to the `Node` type, so AdminAPI calls can expose
racks for brokers
* Fix the Describe User Scram Credentials for Describe all
users or empty users list.
* confluent-kafka-python is based on librdkafka v2.3.0, see the
librdkafka release notes for a complete list of changes,
enhancements, fixes and upgrade considerations.
* Fri Dec 01 2023 Dirk Müller <dmueller@suse.com>
- update to 2.2.0:
* KIP-339
* IncrementalAlterConfigs API (#1517).
* KIP-554:
* User SASL/SCRAM credentials alteration and description
(#1575).
* Added documentation with an example of FIPS compliant
communication with Kafka cluster.
* Fixed wrong error code parameter name in KafkaError.
* Sun May 07 2023 Dirk Müller <dmueller@suse.com>
- update to 2.1.1:
* Added a new ConsumerGroupState UNKNOWN. The typo state UNKOWN
is deprecated and will be removed in the next major version.
* Fix some Admin API documentation stating -1 for infinite
timeout incorrectly.
* Request timeout can't be infinite.
* Added `set_sasl_credentials`. This new method (on the
Producer, Consumer, and AdminClient) allows modifying the
stored SASL PLAIN/SCRAM credentials that will be used for
subsequent (new) connections to a broker
* Added support for Default num_partitions in CreateTopics
Admin API.
* Added support for password protected private key in
CachedSchemaRegistryClient.
* Add reference support in Schema Registry client.
* Added support for schema references.
* KIP-320: add offset leader epoch methods to the
TopicPartition and Message classes
* KIP-222 Add Consumer Group operations to Admin API.
* KIP-518 Allow listing consumer groups per state.
* KIP-396 Partially implemented: support for
AlterConsumerGroupOffsets.
* Added metadata to `TopicPartition` type and `commit()`
* Added `consumer.memberid()` for getting member id assigned to
* the consumer in a consumer group
* Implemented `nb_bool` method for the Producer, so that the
default (which uses len) will not be used.
This avoids situations where producers with
no enqueued items would evaluate to False
* Deprecated `AvroProducer` and `AvroConsumer`. Use
`AvroSerializer` and `AvroDeserializer` instead.
* Deprecated `list_groups`. Use `list_consumer_groups` and
`describe_consumer_groups` instead.
* Improved Consumer Example to show atleast once semantics.
* Improved Serialization and Deserialization Examples.
* Documentation Improvements.
* Mon Sep 26 2022 Yogalakshmi Arunachalam <yarunachalam@suse.com>
- Update to Version 1.9.2:
v1.9.2 is a maintenance release with the following fixes and enhancements:
- Support for setting principal and SASL extensions in oauth_cb
and handle failures (@Manicben, #1402)
- Wheel for macOS M1/arm64
- KIP-140 Admin API ACL fix:
When requesting multiple create_acls or delete_acls operations,
if the provided ACL bindings or ACL binding filters are not
unique, an exception will be thrown immediately rather than later
when the responses are read. (#1370).
- KIP-140 Admin API ACL fix:
Better documentation of the describe and delete ACLs behavior
when using the MATCH resource patter type in a filter. (#1373).
- Avro serialization examples:
added a parameter for using a generic or specific Avro schema. (#1381).
confluent-kafka-python is based on librdkafka v1.9.2, see the
[librdkafka release notes](https://github.com/edenhill/librdkafka/releases/tag/v1.9.2)
for a complete list of changes, enhancements, fixes and upgrade considerations.
- Update to Version v1.9.1:
There was no 1.9.1 release of the Python Client.
- Update to Versino 1.9.0:
This is a feature release:
- OAUTHBEARER OIDC support
- KIP-140 Admin API ACL support
[#]## Fixes
- The warnings for `use.deprecated.format` (introduced in v1.8.2)
had its logic reversed, which result in warning logs to be emitted when
the property was correctly configured, and the log message itself also
contained text that had it backwards.
The warning is now only emitted when `use.deprecated.format` is set
to the old legacy encoding (`True`). #1265
- Use `str(Schema)` rather than `Schema.to_json` to prevent fastavro
from raising exception `TypeError: unhashable type: 'mappingproxy'`.
(@ffissore, #1156, #1197)
- Fix the argument order in the constructor signature for
AvroDeserializer/Serializer: the argument order in the constructor
signature for AvroDeserializer/Serializer was altered in v1.6.1, but
the example is not changed yet. (@DLT1412, #1263)
- Fix the json deserialization errors from `_schema_loads` for
valid primitive declarations. (@dylrich, #989)
confluent-kafka-python is based on librdkafka v1.9.0, see the
[librdkafka release notes](https://github.com/edenhill/librdkafka/releases/tag/v1.9.0)
for a complete list of changes, enhancements, fixes and upgrade considerations.
- Update to Version v1.8.2:
v1.8.2 is a maintenance release with the following fixes and enhancements:
- **IMPORTANT**: Added mandatory `use.deprecated.format` to
`ProtobufSerializer` and `ProtobufDeserializer`.
See **Upgrade considerations** below for more information.
- **Python 2.7 binary wheels are no longer provided.**
Users still on Python 2.7 will need to build confluent-kafka from source
and install librdkafka separately, see [README.md](README.md#Prerequisites)
for build instructions.
- Added `use.latest.version` and `skip.known.types` (Protobuf) to
the Serializer classes. (Robert Yokota, #1133).
- `list_topics()` and `list_groups()` added to AdminClient.
- Added support for headers in the SerializationContext (Laurent Domenech-Cabaud)
- Fix crash in header parsing (Armin Ronacher, #1165)
- Added long package description in setuptools (Bowrna, #1172).
- Documentation fixes by Aviram Hassan and Ryan Slominski.
- Don't raise AttributeError exception when CachedSchemaRegistryClient
constructor raises a valid exception.
confluent-kafka-python is based on librdkafka v1.8.2, see the
[librdkafka release notes](https://github.com/edenhill/librdkafka/releases/tag/v1.8.2)
for a complete list of changes, enhancements, fixes and upgrade considerations.
* *Note**: There were no v1.8.0 and v1.8.1 releases.
[#]# Upgrade considerations
[#]## Protobuf serialization format changes
Prior to this version the confluent-kafka-python client had a bug where
nested protobuf schemas indexes were incorrectly serialized, causing
incompatibility with other Schema-Registry protobuf consumers and producers.
This has now been fixed, but since the old defect serialization and the new
correct serialization are mutually incompatible the user of
confluent-kafka-python will need to make an explicit choice which
serialization format to use during a transitory phase while old producers and
consumers are upgraded.
The `ProtobufSerializer` and `ProtobufDeserializer` constructors now
both take a (for the time being) configuration dictionary that requires
the `use.deprecated.format` configuration property to be explicitly set.
Producers should be upgraded first and as long as there are old (<=v1.7.0)
Python consumers reading from topics being produced to, the new (>=v1.8.2)
Python producer must be configured with `use.deprecated.format` set to `True`.
When all existing messages in the topic have been consumed by older consumers
the consumers should be upgraded and both new producers and the new consumers
must set `use.deprecated.format` to `False`.
The requirement to explicitly set `use.deprecated.format` will be removed
in a future version and the setting will then default to `False` (new format).
* Sat Oct 30 2021 Dirk Müller <dmueller@suse.com>
- update to 1.7.0:
* Add error_cb to confluent_cloud.py example
* Clarify that doc output varies based on method
* Docs say Schema when they mean SchemaReference
* Add documentation for NewTopic and NewPartitions
* Mon Apr 26 2021 Dirk Müller <dmueller@suse.com>
- update to 1.6.1:
* KIP-429 - Incremental consumer rebalancing support.
* OAUTHBEARER support.
* Add return_record_name=True to AvroDeserializer
* Fix deprecated schema.Parse call
* Make reader schema optional in AvroDeserializer
* Add **kwargs to legacy AvroProducer and AvroConsumer constructors to
* support all Consumer and Producer base class constructor arguments, such
* as logger
* Add bool for permanent schema delete
* The avro package is no longer required for Schema-Registry support
* Only write to schema cache once, improving performance
* Improve Schema-Registry error reporting
* producer.flush() could return a non-zero value without hitting the specified timeout.
* Bundles librdkafka v1.6.0 which adds support for Incremental rebalancing,
* Sticky producer partitioning, Transactional producer scalabilty improvements,
* and much much more. See link to release notes below.
* Rename asyncio.py example to avoid circular import
* The Linux wheels are now built with manylinux2010 (rather than manylinux1)
* since OpenSSL v1.1.1 no longer builds on CentOS 5. Older Linux distros may
* thus no longer be supported, such as CentOS 5.
* The in-wheel OpenSSL version has been updated to 1.1.1i.
* Added Message.latency() to retrieve the per-message produce latency.
* Added trove classifiers.
* Consumer destructor will no longer trigger consumer_close(),
* consumer.close() must now be explicitly called if the application
* wants to leave the consumer group properly and commit final offsets.
* Fix PY_SSIZE_T_CLEAN warning
* Move confluent_kafka/ to src/ to avoid pytest/tox picking up the local dir
* Added producer.purge() to purge messages in-queue/flight
* Added AdminClient.list_groups() API
* Rename asyncio.py example to avoid circular import
/usr/lib64/python3.14/site-packages/confluent_kafka /usr/lib64/python3.14/site-packages/confluent_kafka-2.14.0.dist-info /usr/lib64/python3.14/site-packages/confluent_kafka-2.14.0.dist-info/INSTALLER /usr/lib64/python3.14/site-packages/confluent_kafka-2.14.0.dist-info/METADATA /usr/lib64/python3.14/site-packages/confluent_kafka-2.14.0.dist-info/RECORD /usr/lib64/python3.14/site-packages/confluent_kafka-2.14.0.dist-info/REQUESTED /usr/lib64/python3.14/site-packages/confluent_kafka-2.14.0.dist-info/WHEEL /usr/lib64/python3.14/site-packages/confluent_kafka-2.14.0.dist-info/licenses /usr/lib64/python3.14/site-packages/confluent_kafka-2.14.0.dist-info/licenses/LICENSE /usr/lib64/python3.14/site-packages/confluent_kafka-2.14.0.dist-info/top_level.txt /usr/lib64/python3.14/site-packages/confluent_kafka/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/_types.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/_types.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/deserializing_consumer.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/deserializing_consumer.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/error.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/error.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/serializing_producer.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/__pycache__/serializing_producer.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/_model /usr/lib64/python3.14/site-packages/confluent_kafka/_model/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/_model/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/_model/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/_model/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/_types.py /usr/lib64/python3.14/site-packages/confluent_kafka/_util /usr/lib64/python3.14/site-packages/confluent_kafka/_util/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/_util/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/_util/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/_util/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/_util/__pycache__/conversion_util.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/_util/__pycache__/conversion_util.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/_util/__pycache__/validation_util.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/_util/__pycache__/validation_util.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/_util/conversion_util.py /usr/lib64/python3.14/site-packages/confluent_kafka/_util/validation_util.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_acl.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_acl.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_cluster.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_cluster.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_config.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_config.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_group.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_group.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_listoffsets.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_listoffsets.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_metadata.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_metadata.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_records.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_records.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_resource.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_resource.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_scram.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_scram.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_topic.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/__pycache__/_topic.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_acl.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_cluster.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_config.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_group.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_listoffsets.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_metadata.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_records.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_resource.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_scram.py /usr/lib64/python3.14/site-packages/confluent_kafka/admin/_topic.py /usr/lib64/python3.14/site-packages/confluent_kafka/aio /usr/lib64/python3.14/site-packages/confluent_kafka/aio/_AIOConsumer.py /usr/lib64/python3.14/site-packages/confluent_kafka/aio/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/aio/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/aio/__pycache__/_AIOConsumer.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/__pycache__/_AIOConsumer.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/__pycache__/_common.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/__pycache__/_common.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/_common.py /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/_AIOProducer.py /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_AIOProducer.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_AIOProducer.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_buffer_timeout_manager.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_buffer_timeout_manager.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_kafka_batch_executor.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_kafka_batch_executor.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_message_batch.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_message_batch.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_producer_batch_processor.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/__pycache__/_producer_batch_processor.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/_buffer_timeout_manager.py /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/_kafka_batch_executor.py /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/_message_batch.py /usr/lib64/python3.14/site-packages/confluent_kafka/aio/producer/_producer_batch_processor.py /usr/lib64/python3.14/site-packages/confluent_kafka/avro /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__pycache__/cached_schema_registry_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__pycache__/cached_schema_registry_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__pycache__/error.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__pycache__/error.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__pycache__/load.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/__pycache__/load.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/cached_schema_registry_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/avro/error.py /usr/lib64/python3.14/site-packages/confluent_kafka/avro/load.py /usr/lib64/python3.14/site-packages/confluent_kafka/avro/serializer /usr/lib64/python3.14/site-packages/confluent_kafka/avro/serializer/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/avro/serializer/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/avro/serializer/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/serializer/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/serializer/__pycache__/message_serializer.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/serializer/__pycache__/message_serializer.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/avro/serializer/message_serializer.py /usr/lib64/python3.14/site-packages/confluent_kafka/cimpl.cpython-314-x86_64-linux-gnu.so /usr/lib64/python3.14/site-packages/confluent_kafka/cimpl.pyi /usr/lib64/python3.14/site-packages/confluent_kafka/deserializing_consumer.py /usr/lib64/python3.14/site-packages/confluent_kafka/error.py /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__pycache__/verifiable_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__pycache__/verifiable_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__pycache__/verifiable_consumer.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__pycache__/verifiable_consumer.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__pycache__/verifiable_producer.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/__pycache__/verifiable_producer.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/verifiable_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/verifiable_consumer.py /usr/lib64/python3.14/site-packages/confluent_kafka/kafkatest/verifiable_producer.py /usr/lib64/python3.14/site-packages/confluent_kafka/py.typed /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/avro.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/avro.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/error.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/error.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/json_schema.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/json_schema.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/protobuf.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/protobuf.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/rule_registry.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/rule_registry.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/schema_registry_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/schema_registry_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/serde.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/serde.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/wildcard_matcher.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/__pycache__/wildcard_matcher.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/avro.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/avro.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/json_schema.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/json_schema.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/mock_schema_registry_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/mock_schema_registry_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/protobuf.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/protobuf.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/schema_registry_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/schema_registry_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/serde.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/__pycache__/serde.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/avro.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/json_schema.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/mock_schema_registry_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/protobuf.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/schema_registry_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_async/serde.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/avro.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/avro.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/json_schema.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/json_schema.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/mock_schema_registry_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/mock_schema_registry_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/protobuf.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/protobuf.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/schema_registry_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/schema_registry_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/serde.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/__pycache__/serde.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/avro.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/json_schema.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/mock_schema_registry_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/protobuf.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/schema_registry_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/_sync/serde.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/avro.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/_oauthbearer.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/_oauthbearer.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/avro.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/avro.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/json_schema.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/json_schema.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/protobuf.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/protobuf.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/schema_registry_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/schema_registry_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/serde.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/__pycache__/serde.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/_oauthbearer.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/avro.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/json_schema.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/protobuf.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/schema_registry_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/common/serde.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/__pycache__/meta_pb2.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/__pycache__/meta_pb2.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/meta_pb2.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/types /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/types/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/types/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/types/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/types/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/types/__pycache__/decimal_pb2.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/types/__pycache__/decimal_pb2.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/confluent/types/decimal_pb2.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/error.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/json_schema.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/protobuf.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rule_registry.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/cel_executor.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/cel_executor.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/cel_field_executor.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/cel_field_executor.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/cel_field_presence.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/cel_field_presence.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/constraints.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/constraints.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/extra_func.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/extra_func.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/string_format.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/__pycache__/string_format.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/cel_executor.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/cel_field_executor.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/cel_field_presence.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/constraints.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/extra_func.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/cel/string_format.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/__pycache__/encrypt_executor.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/__pycache__/encrypt_executor.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/__pycache__/kms_driver_registry.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/__pycache__/kms_driver_registry.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/awskms /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/awskms/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/awskms/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/awskms/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/awskms/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/awskms/__pycache__/aws_driver.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/awskms/__pycache__/aws_driver.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/awskms/aws_driver.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__pycache__/azure_aead.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__pycache__/azure_aead.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__pycache__/azure_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__pycache__/azure_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__pycache__/azure_driver.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/__pycache__/azure_driver.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/azure_aead.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/azure_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/azurekms/azure_driver.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/__pycache__/dek_registry_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/__pycache__/dek_registry_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/__pycache__/mock_dek_registry_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/__pycache__/mock_dek_registry_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/dek_registry_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/dek_registry/mock_dek_registry_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/encrypt_executor.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/__pycache__/gcp_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/__pycache__/gcp_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/__pycache__/gcp_driver.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/__pycache__/gcp_driver.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/gcp_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/gcpkms/gcp_driver.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/__pycache__/hcvault_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/__pycache__/hcvault_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/__pycache__/hcvault_driver.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/__pycache__/hcvault_driver.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/hcvault_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/hcvault/hcvault_driver.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/kms_driver_registry.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/__pycache__/local_client.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/__pycache__/local_client.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/__pycache__/local_driver.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/__pycache__/local_driver.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/local_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/encryption/localkms/local_driver.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/jsonata /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/jsonata/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/jsonata/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/jsonata/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/jsonata/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/jsonata/__pycache__/jsonata_executor.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/jsonata/__pycache__/jsonata_executor.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/rules/jsonata/jsonata_executor.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/schema_registry_client.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/serde.py /usr/lib64/python3.14/site-packages/confluent_kafka/schema_registry/wildcard_matcher.py /usr/lib64/python3.14/site-packages/confluent_kafka/serialization /usr/lib64/python3.14/site-packages/confluent_kafka/serialization/__init__.py /usr/lib64/python3.14/site-packages/confluent_kafka/serialization/__pycache__ /usr/lib64/python3.14/site-packages/confluent_kafka/serialization/__pycache__/__init__.cpython-314.opt-1.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/serialization/__pycache__/__init__.cpython-314.pyc /usr/lib64/python3.14/site-packages/confluent_kafka/serializing_producer.py /usr/share/doc/packages/python314-confluent-kafka /usr/share/doc/packages/python314-confluent-kafka/README.md /usr/share/licenses/python314-confluent-kafka /usr/share/licenses/python314-confluent-kafka/LICENSE
Generated by rpm2html 1.8.1
Fabrice Bellet, Sun Apr 19 22:35:28 2026