最新想用starrocks-connector-for-apache-flink来连接公司平台的Flink和SR,但是公司平台的Flink目前只有1.7和1.9版本,以1.7版本为主,而starrocks-connector-for-apache-flink 的最低支持版本是1.11版本。
目前计划的方案如下:
- 基于1.7版本另写starrocks-connector-for-apache-flink,但是不知道当时不支持低版本Flink的原因是什么,是不是开发时遇到了某些坑;
- 在公司平台之外另布一个版本较高的Flink,但需要额外的数据转发和维护;
- 使用kafka routine load来代替flink connector,但需要额外的一步kafka转发,而且不知道效率比起flink connector来如何。
请帮忙看看哪个方案更合适点,感谢!