Avro Format
更新时间: 2021-11-16 14:15:50
阅读 263
Avro Format
Avro Format允许我们基于 Avro schema 进行解析和生成 Avro 数据。
用例
CREATE TABLE user_behavior (
user_id BIGINT,
item_id BIGINT,
category_id BIGINT,
behavior STRING,
ts TIMESTAMP(3)
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
'properties.bootstrap.servers' = 'localhost:9092',
'properties.group.id' = 'testGroup',
'format' = 'avro'
)
SET 'user_behavior.format'='avro';
Format参数
参数 | 是否必填 | 默认值 | 类型 | 描述 |
---|---|---|---|---|
format | 必填 | none | String | ‘avro’ |
avro.codec | 选填 | none | String | 只针对filesystem conenctor有效,默认snappy,其他:null,deflate,bzip2,xz |
文档反馈
以上内容对您是否有帮助?