你好
我在使用kafka produce数据后，在python中使用UDF做一个add function，但
是最后的sink文件里面没有任何数据，
如果不用UDF的话直接获取一个数据在最后的sink文件里面是有数据的如下所示，DEBUG
很久也不清楚是什么原因是否能帮忙分下
Kafka用的测试数据 {"a": "bbb", "b": 3, "c": 1}
测试结果
Kafka用的测试数据 {"a": "bbb", "b": 3, "c": 1}
st_env.from_path("source")\
这个问题定义了
我用了两个kafka包，其中红色的包是不需要的，非常感谢你们的帮助
flink-connector-kafka_2.11-1.10.0.jar
flink-sql-connector-kafka_2.11-1.10.0.jar
发件人: 秦寒
发送时间: 2020年4月10日 10:15
收件人: 'Hequn Cheng' ; 'user-zh'
主题: 回复: 关于kafka connector通过python链接
这个搞定了，pip3重装了一下apache flink，引入了jar包搞定
发
这个搞定了，pip3重装了一下apache flink，引入了jar包搞定
发件人: 秦寒
发送时间: 2020年4月9日 16:41
收件人: 'Hequn Cheng' ; 'user-zh'
主题: 回复: 关于kafka connector通过python链接
您好
根据你们的说明我做了如下配置，我用的是flink 1.10版本
1在pyflink/lib下面添加了kafka-clients-2.2.0.jar
2 在build-target/lib下面添加了flink-sql-
pip install dist/*.tar.gz
4 执行测试程序tumble_window.py报错如下，不知道你们有没有遇见过这个错误，望能解答
[yy1s@rbtnode1 project]$ python3 tumble_window.py
发件人: Hequn Cheng
发送时间: 2020年4月9日 10:08
收件人: user-zh
抄送: han...@chinaums.com
主题: Re: 关于kafka connector通过python链接
Hi 秦寒，
Dian 说得很完善了。除此之外，金竹的博客[1
您好
Flink的 kafka connector 文档中只有java 和scala的列子，能否添加python
调用kafka的列子，包括如何添加kafka connector，kafka client的jar包配置到pyhon
环境等，谢谢。
