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 的表里头了,应用系统就直接读取使用了