ksqlDB支持使用Schema Registry格式串行化的Protobuf。要将您的数据指定为protobuf，请使用
我想使用ksqldb对以proto缓冲区格式编码的流式数据进行一些查询。但我不知道如何实现。如果二进制消息数据是纯c结构，如何解码c结构消息并对流数据应用查询？
FORMAT='PROTOBUF'，例如
CREATE STREAM my_stream
WITH (KAFKA_TOPIC='my_topic',
FORMAT='PROTOBUF');
架构本身是从架构注册表中提取的。
有关更多详细信息，请参阅https://docs.ksqldb.io/en/latest/reference/serialization/