Hi Vikash, It's a bug about classloader used in `abortTransaction()` method in `FlinkKafkaProducer`, Flink version 1.10.0. I think it has been fixed in 1.10.1 and 1.11 according to FLINK-16262. Are you using Flink version 1.10.0?
Vikash Dat <dat.vik...@gmail.com> 于2020年7月30日周四 下午9:26写道： > Has anyone had success with using exactly_once in a kafka producer in > flink? > As of right now I don't think the code shown in the docs > ( > https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#kafka-producer > ) > actually works. > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ > -- Best Regards, *Qingsheng Ren* Electrical and Computer Engineering Carnegie Mellon University Email: renqs...@gmail.com
