pulsar sink 无法消费

2020-12-28  本文已影响0人  无我_a50f

排查步骤:

  1. 不要使用 create 创建sink
  2. 使用 localrun 方式创建 sink 可以看到报错
  3. 使用 绝对路径,相对路径可能会找不到文件(我这里出现问题是因为删除了原来版本的包,使用了2.6.1版本)
  4. sink 的 topic 和数据发送的 topic 不一致
  5. sink 的 topic 需要预先设置 schema
上一篇下一篇

猜你喜欢

热点阅读