confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== I get a SIGSEGV crashing my entire application when trying to construct an AvroProducer. I'm unclear if there is a problem with my configuration or not, but a...
Fix: add default value for version as it said in method description.
Fixed few mismached URLs and missing default value for a parameter.
Add missing methods to `SchemaRegistryClient` for REST API : - [x] `get_schema_types() -> list(str)` - [x] `get_schema_versions(schema_id: int) -> list(dict)` - [ ] `get_schema_by_subject_version(subject_name:str, version:int) -> Schema` - needs discussion...
Currently `SchemaRegistryClient` method have different schema object for different method for example: `get_latest_version` return you schema with references as array of json as below ``` [{'name': 'com.test.common.event.Eventdata', 'subject': 'com.test.common.event.Eventdata', 'version':...
**Description:** I am encountering discrepancies between the metrics displayed on the Confluent Platform website for my Kafka topics and the actual consumption and production counts observed in my environment. Specifically,...
Description =========== This message spams our log. Is it a real error, or can this be ignored? ``` %3|1720719719.448|FAIL|rdkafka#consumer-2| [thrd:GroupCoordinator]: GroupCoordinator: SASL authentication error: SaslAuthenticateRequest failed: Local: Broker transport failure...
Description =========== `SchemaRegistryClient` is based on **requests**, which is basically _sync_. Therefore it is not suitable for _async_ applications. I suggest to implement `AsyncSchemaRegistryClient` based on **aiohttp**.
