一点小小的建议哈,
目前flink社区讨论主要还是java/scala为主,
如果执意使用pyflink的话,后续极有可能会遇到较大的阻力.








在 2021-01-31 14:26:55,"瞿叶奇" <389243...@qq.com> 写道:
>您好,我是国网陕西采集系统开发人员,我们在架构改造中,准备使用pyflink 
>解决实时Kafka数据写HDFS的问题,我的Kafka集群存在kerberos安全认证,导致我现在还没连接上,能不能给一个样例呢?

回复