confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== ```get_latest_schema()``` method in ```cached_schema_registry_client.py``` have the below code which makes it difficult to debug the actual error code ``` elif not (code >= 200 and code
This is a feature request. We have encountered a problem in production. Our Kafka ops were doing some maintenance of the cluster, during which a HTTP request to schema registry...
Hi, I was trying to run the avro producer and got the following error. value_schema = avro.load('ValueSchema.avsc') File "/usr/local/lib/python2.7/site-packages/confluent_kafka/avro/__init__.py", line 22, in load with open(fp) as f: IOError: [Errno 2]...
Description =========== AvroConsumer happily returns decoded Avro messages, but drops all reference to the original Avro schema/identifier. The schema is super-useful in some cases (eg. Debezium, where it contains the...
Description =========== Avro message schemas usually carry important information, `namespace` and `name`. For example, in Java API, both specific and generic Avro records have schema available via `getSchema`. These `namespace`...
Description =========== I use Pycharm as my IDE, and I dislike seeing complaints about type mismatch. The `value` attribute of Message objects is typed as `Optional[Union[str, bytes]]`. However, `AvroConsumer`s set...
Description =========== There seems to have been a bug introduced in #470 that meant that, unless reader schemas are manually specified in the `AvroConsumer` constructor, attempts to use `fastavro` will...
Description =========== `confluent_kafka` should allow for future compatible versions of `avro` as dependencies. `setup.py` specifies `avro==1.10.0`, but several releases of `avro` have come out since then. It's currently impossible to...
Description =========== The confluent schema registry (java) recently added support for handling of custom protobuf options. What that meant was that both declarations of custom options, as well as invocations...
Product: Confluent Cloud / confluent_kafka Using confluent-kafka 2.1.0 We were trying to follow the instructions [here](https://www.confluent.io/blog/multiple-event-types-in-the-same-kafka-topic/) to configure the schema on one of our topics to be an Avro union....
