flinkStreamSQL icon indicating copy to clipboard operation
flinkStreamSQL copied to clipboard

Published 20 hours ago • verified publisher icon DTStack

支持多版本kafka在一个任务吗

Open myCodingTrip opened this issue 6 years ago • 4 comments

例如读kafka09写入kafka11，我测的好像会造成jar包冲突，报错 java.lang.NoSuchMethodError: org.apache.kafka.clients.producer.ProducerRecord.(Ljava/lang/String;Ljava/lang/Integer;Ljava/lang/Long;Ljava/lang/Object;Ljava/lang/Object;)V

myCodingTrip avatar Sep 26 '19 09:09 myCodingTrip

你这个是用什么模式启动的，yarn，还是standalone模式

yangsishu avatar Sep 26 '19 11:09 yangsishu

本地模式跑的

myCodingTrip avatar Sep 27 '19 01:09 myCodingTrip

这个代码有问题

yangsishu avatar Oct 14 '19 10:10 yangsishu

kafka0.8 0.9 1.x 2.x 版本客户端协议差异较大 不同版本的之间的生产消费兼容性较差 不有问题，不建议这样玩

Rowen110 avatar Sep 15 '20 08:09 Rowen110