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