我正试图用以下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