1
liprais 92 天前
自己写个呗
|
2
8355 92 天前
clickhouse 不是有个 kafka 引擎吗 通过试图写入到表啊?
|
3
lbp0200 92 天前
流计算 Oceanus 是大数据产品生态体系的实时化分析利器,是基于 Apache Flink 构建的企业级实时大数据分析平台,具备一站开发、无缝连接、亚秒延时、低廉成本、安全稳定等特点。流计算 Oceanus 以实现企业数据价值最大化为目标,加速企业实时化数字化的建设进程。
楼主先了解下什么是 Apache Flink |
6
haimianbihdata 92 天前 via Android
直接 flink cdc 过来啊
|
7
magotcai OP @haimianbihdata 看了下,cdc 得 source 好像没有 kafka ,sink 也没有 clickhouse ,应该得自己实现吧
|
8
haimianbihdata 91 天前 via Android
等等,你的源头是 kafka 吗?
|
9
magotcai OP @haimianbihdata 是的 源是 kafka
|
10
magotcai OP @haimianbihdata 用了 seatunnel 还可以
|
11
haimianbihdata 90 天前 via Android
seatunnel 可以用自带的 zeta 引擎,我只是跑了一个 demo 好久前了,不过我看社区是推荐这个的
|
12
haimianbihdata 90 天前 via Android
|