Hi Marco, Sorry I forgot to cc the user mailing list just now.
From the exception message it looks like a versioning issue. Could you provide some additional information, such as Flink & Kafka connector version, Kafka broker version, and full exception stack? Also it will be helpful to paste part of your code (on DataStream API) or SQL (on Table & SQL API). -- Best Regards, Qingsheng Ren Email: renqs...@gmail.com On Oct 19, 2021, 9:28 AM +0800, Marco Villalobos <mvillalo...@kineteque.com>, wrote: > I have the simplest Flink job that simply deques off of a kafka topic and > writes to another kafka topic, but with headers, and manually copying the > event time into the kafka sink. > > It works as intended, but sometimes I am getting this error: > > org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to > write a non-default producerId at version 1. > > Does anybody know what this means and how to fix this? > > Thank you. >
