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.
