排查步骤：
- 不要使用 create 创建sink
- 使用 localrun 方式创建 sink 可以看到报错
- 使用 绝对路径，相对路径可能会找不到文件（我这里出现问题是因为删除了原来版本的包，使用了2.6.1版本）
- sink 的 topic 和数据发送的 topic 不一致
- sink 的 topic 需要预先设置 schema
排查步骤：
排查步骤： 不要使用 create 创建sink 使用 localrun 方式创建 sink 可以看到报错 使用 ...
摘要 在 Pulsar 中，Function、Source 和 Sink 都是运行在 Function Worke...
摘要 在 Pulsar 中，Function、Source 和 Sink 都是运行在 Function Worke...
阅读本文需要约 20 分钟。 1. 概览 Apache Pulsar 是一个分布式的发布-订阅消息系统，sink ...
背景 Pulsar Connector 系列的前几篇文章已介绍了 Source、Sink 与 Producer、C...
一、Pulsar Connector 连接器 虽然可以使用 Pulsar 消费者和生产者 API 编写代码（例如，...
一、添加pom.xml依赖 二、Pulsar 参数类 三、Pulsar 配置类 四、不同消费数据类型的监听器 五、...
本文默认大家对 Pulsar 和 Kafka 都有一定的了解。 kafka kafka 属于 Stream 的消费...
介绍 Sink运行器（Sink Runner）运行一个Sink组（Sink Group），Sink组可以含有一个或...
前言 Sink运行器（Sink Runner）运行一个Sink组（Sink Group），Sink组可以含有一个或...
本文标题：pulsar sink 无法消费
本文链接：https://www.haomeiwen.com/subject/wlbznktx.html
网友评论