kafka写入starRocks时将数据以分区形式存入表

[Roc_001]

我用kafka接入starRocks,数据是一行数据一直在实时更新,如下

刷新后:

时间变化了,数据只是以一条数据的形式存在,一直在不停刷新.
能否将kafka接入的数据保存至starRocks表,并以当前时间的小时为分区一直插入数据至starRocks表.

[LIANGCHAOHUA]

kafka+flink+主键模型实现吗？

[Roc_001]

是的,类似这样的实现