提问人：Xiaoyong Guo 提问时间：1/20/2022 更新时间：1/21/2022 访问量：290
如何配置 ksqldb 来理解 kafka 中的二进制 proto-buffer 消息？
How can I config ksqldb to understand binary proto-buffer message in kafka?
问：
我想使用 ksqldb 对以 proto-buffer 格式编码的流数据进行一些查询。 但我不知道如何实现它。如果二进制消息数据是纯 c 结构，如何解码 c-struct 消息并对流数据应用查询？
答：
2赞
Robin Moffatt
1/21/2022
#1
ksqlDB 支持使用 Schema Registry 格式序列化的 Protobuf。要将您的数据指定为 protobuf，请使用例如FORMAT='PROTOBUF'
CREATE STREAM my_stream
WITH (KAFKA_TOPIC='my_topic',
FORMAT='PROTOBUF');
架构本身是从架构注册表中获取的。
有关详细信息，请参阅 https://docs.ksqldb.io/en/latest/reference/serialization/
评论