Rocketmq Sink

简述

Easystream 支持输出到 Rocketmq。

示例

  1. create table sink(
  2.   `key` varchar,
  3.   `value` VARCHAR
  4. ) with(
  5.    'connector.type' = 'rocketmq',
  6.    'nameserver.address' = 'xxx:9876;xxx:9876',
  7.    'group' = 'sloth-test-sink-0117-01',
  8.    'topic' = 'sloth-test-0117-01',
  9.    'brokerserver.heartbeat.interval' = '30000',
  10.    'async' = 'true',
  11.    'retry.times' = '3',
  12.    'timeout' = '3000',
  13.    'flash.on.checkpoint' = 'true',
  14.    'msg.delay.level' = '0'
  15. );

With 参数

参数 注释说明 备注
connector.type 数据源类型 必填，’rocketmq’，小写
nameserver.address rocketmq 服务地址 必填
group 写入的组 必填
topic 写入的 topic 必填
brokerserver.heartbeat.interval 与 brokerserver 的心跳间隔 选填，默认是 30000ms
async 是否开启异步写入 选填，默认为 false
retry.times async=true 时的重试次数 选填，默认3次
flash.on.checkpoint 是否每次打 checkpoint 时才刷新数据到目标端 选填，默认为 false
msg.delay.level 数据的发送级别 选填，默认为0