一点小小的建议哈, 目前flink社区讨论主要还是java/scala为主, 如果执意使用pyflink的话,后续极有可能会遇到较大的阻力.
在 2021-01-31 14:26:55,"瞿叶奇" <389243...@qq.com> 写道: >您好,我是国网陕西采集系统开发人员,我们在架构改造中,准备使用pyflink >解决实时Kafka数据写HDFS的问题,我的Kafka集群存在kerberos安全认证,导致我现在还没连接上,能不能给一个样例呢?
一点小小的建议哈, 目前flink社区讨论主要还是java/scala为主, 如果执意使用pyflink的话,后续极有可能会遇到较大的阻力.
在 2021-01-31 14:26:55,"瞿叶奇" <389243...@qq.com> 写道: >您好,我是国网陕西采集系统开发人员,我们在架构改造中,准备使用pyflink >解决实时Kafka数据写HDFS的问题,我的Kafka集群存在kerberos安全认证,导致我现在还没连接上,能不能给一个样例呢?