|
|
|
|
|
by sauljp
699 days ago
|
|
Hi! it validates if the message was (or not) generated for schema registry, it checks if the message has the schema registry magic bytes (this bytes has the schema id). so, it deserializes messages with or without schema registry. This is the drawback: you have to generate the descriptor first. 1) download the schema from schema registry:
http :8081/schemas/ids/<my-id>/schema 2) generate the descriptor with the schema:
protoc --include_imports --descriptor_set_out=my-descriptor.desc --proto_path=. my-schema.proto 3) use kaskade:
kaskade consumer -b my-kafka:9092 -x auto.offset.reset=earliest -k string -v protobuf -t my-protobuf-topic -p descriptor=my-descriptor.desc -p value=mypackage.MyMessage |
|