卡夫卡流中的普罗托布夫字节字段



我正试图用以下ksql命令在ksql-cli中创建一个kafka流。从命令中可以看出,流的来源是kafka主题。

CREATE STREAM
TestStream
WITH
(
kafka_topic = 'testtopic',
value_format = 'PROTOBUF'
);

这个kafka主题,使用模式注册表,具有protobuf格式。架构如下。


message TestSchema {
optional string deviceId = 1;
required bytes  mac = 2;
optional uint32 inNetwork = 3;
optional sint32 rssi = 4;
optional bool auth = 5;
}

此时,当新消息生成kafka主题时,我在流中看不到bytes mac字段。其他字段,(deviceId、inNetwork、rssi和auth(按预期显示。我认为ksql中不支持protobuf的字节字段。

是否可以使字节由流支持?或者,是否可以在流创建中以某种方式将字节转换为字符串?

我自己刚刚开始研究这个问题。目前似乎不支持字节:https://github.com/confluentinc/ksql/issues/1742

相关内容

  • 没有找到相关文章

最新更新