python-schema-registry-client

python-schema-registry-client copied to clipboard

**Describe the bug** I have with two first examples of readme of your project, i have this error **json.decoder.JSONDecodeError: Expecting value: line 1 column 1 (char 0)** **full error** ```...

gustavoDanielT

MessageSerializer.encode... functions not serializing proper Avro

4

**Describe the bug** The MessageSerializer.encode... functions don't output proper Avro. When serializing a record using MessageSerializer/FaustSerializer the binary doesn't conform to proper Avro, and isn't parsed properly when read back...

xgamer4

Rename serializer methods

6

decode_message --> deserialize encode_record_with_schema_id --> serialize. Potentially, only 1 serialization method should be available that could receive either a schema_id or a Schema object.

marcosschroh

Create Event class to use with the serializer.

1

When `encode_record_with_schema_id` or `encode_record_with_schema` is called with `data/record`, these methods should return an `Event object` containing the `data/record`, the `payload` (the data encoded), the `schema_id` used to serialize the data...

marcosschroh

marcosschroh

marcosschroh

Faust Generic Serializer

4

**Feature Request✨** While I may be treating the package incorrectly, it appears that, by intention, there exists one serializer per schema. I was interested in a generic serializer that took...

Irate-Walrus

Support for protobuf schemas

1

**Is your feature request related to a problem? Please describe.** In a Microsoft environment, protobuf is generally preferred to Avro and JSON Schema. It would be nice to be able...

martimors

I am building a streaming application designed to ingest messages of varying schemas and analyse a subset of their fields, based on information held within the schema E.g. Any producer...

Robbie-Palmer

AsyncSchemaRegistryClient is unable to handle concurrent requests

9

**Describe the bug** Related to https://github.com/encode/httpx/issues/1478, I'm getting this exception while using the same instance of `AsyncSchemaRegistryClient` in two different places, raising `httpx.RemoteProtocolError: can't handle event type ConnectionClosed when role=SERVER...

thiromi