你好
我在使用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包搞定
发件人: 秦寒 < <mail
这个搞定了,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-connector-kafka_2.11
您好
Flink的 kafka connector 文档中只有java 和scala的列子,能否添加python
调用kafka的列子,包括如何添加kafka connector,kafka client的jar包配置到pyhon
环境等,谢谢。