-
-
Notifications
You must be signed in to change notification settings - Fork 18
Open
Labels
Description
It's necessary that confluent-kafka-python provides support for this. It has it for java.
Right now the DESCRIPTOR is needed https://github.com/confluentinc/confluent-kafka-python/blob/master/src/confluent_kafka/schema_registry/protobuf.py#L482.
- Extract the MessageIndexes https://github.com/confluentinc/schema-registry/blob/master/protobuf-serializer/src/main/java/io/confluent/kafka/serializers/protobuf/AbstractKafkaProtobufDeserializer.java#L139
- Get the message name from the schema https://github.com/confluentinc/schema-registry/blob/master/protobuf-serializer/src/main/java/io/confluent/kafka/serializers/protobuf/AbstractKafkaProtobufDeserializer.java#L140
- Make the FileDescriptorSet from the proto file got from schema registry (this is the blocker right now)
- Get the class using the message name
- Instantiate the class
Another alternative if using buf:
https://buf.build/docs/bsr/reflection/overview
https://googleapis.dev/python/protobuf/latest/google/protobuf/message_factory.html
Reactions are currently unavailable