pulsar sink 无法消费2020-12-28 本文已影响0人 无我_a50f 排查步骤: 不要使用 create 创建sink 使用 localrun 方式创建 sink 可以看到报错 使用 绝对路径,相对路径可能会找不到文件(我这里出现问题是因为删除了原来版本的包,使用了2.6.1版本) sink 的 topic 和数据发送的 topic 不一致 sink 的 topic 需要预先设置 schema