Hi,

据我所知,flink没有提供对redis connector的官方支持[1],你需要根据官方提供的接口来自定义你的redis
connector,关于如何自定义connector,你可以参考文档[2]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sourceSinks.html

Best,
Xingbo


消息室 <[email protected]> 于2020年12月17日周四 上午9:33写道:

> 您好:
>
> &nbsp; &nbsp; &nbsp;
> 我们项目组计划使用pyflink,有幸拜读了您的博客,我想请教一下当前1.12.0版本的pyflink的sink是否支持redis
> connector?感谢!
> &nbsp; &nbsp; &nbsp; 如不支持,有何建议方式?

回复