Closed sunxiaojian closed 2 years ago
@sunxiaojian 堂老师你好,streams目前暂时会保留其他类型的source和sink,社区里对直接从第三数据源获取数据有需求的。不过后续重点会逐步放到rocketmq的source/sink上,某些功能,比如精确一次、分区动态发现,只有结合rocketmq才能做的更好。
@sunxiaojian 堂老师你好,streams目前暂时会保留其他类型的source和sink,社区里对直接从第三数据源获取数据有需求的。不过后续重点会逐步放到rocketmq的source/sink上,某些功能,比如精确一次、分区动态发现,只有结合rocketmq才能做的更好。
嗯,不光是source的问题, 包括checkpoint ,如果不是 compact topic 模式 的也无法达到弹性扩容
@sunxiaojian 堂老师你好,streams目前暂时会保留其他类型的source和sink,社区里对直接从第三数据源获取数据有需求的。不过后续重点会逐步放到rocketmq的source/sink上,某些功能,比如精确一次、分区动态发现,只有结合rocketmq才能做的更好。
嗯,不光是source的问题, 包括checkpoint ,如果不是 compact topic 模式 的也无法达到弹性扩容
是的,需要compact topic才能达到状态在不同实例间迁移的效果。
RocketMQ streams 会考虑只保留 rocketmq 的source 和sink , 将其它连接器交给 connect 来做吗 ?