kafka 可以这样用了吗?我 out 啦?
一个 kafkaicon 表。
CREATE TABLE user_behave (
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING,
`ts` TIMESTAMP(3) METADATA FROM ‘timestamp’
) WITH (
‘connector’ = ‘kafka’,
‘topic’ = ‘user_behavior’,
‘properties.bootstrap.servers’ = ‘localhost:9092’,
‘properties.group.id’ = ‘testGroup’,
‘scan.startup.mode’ = ‘earliest-offset’,
‘format’ = ‘csv’
)
意思就是将 kakfa topic 映射成了一个表,里头每一行是 csvicon 格式。
回答·1
最热
最新
- 在定义一个结果统计表在 mysqlicon 里头 CREATE TABLE user_stat ( pv BIGINT ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://localhost:3306/mydatabase', 'table-name' = 'users' ); 最后用一个语句就可以实时的计算统计值,并更新到 mysql 的表里头了,应用系统就直接读取使用了