如何配置 ksqldb 以理解 kafka 中的二进制原型缓冲区消息？
How can I config ksqldb to understand binary proto-buffer message in kafka?
我想使用 ksqldb 对以 proto-buffer 格式编码的流数据进行一些查询。
但我不知道如何实现它。如果二进制消息数据是纯 c 结构怎么办，如何解码 c 结构消息并对流数据应用查询？
ksqlDB 支持 serialised using the 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/
我想使用 ksqldb 对以 proto-buffer 格式编码的流数据进行一些查询。 但我不知道如何实现它。如果二进制消息数据是纯 c 结构怎么办，如何解码 c 结构消息并对流数据应用查询？
ksqlDB 支持 serialised using the 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/