How to migrate Kafka Producer ?
I'm planning to migrate from kafka connector 0.11 to the new universal kafka
connector 1.0.0+ but I'm having some troubles.
The kafka consumer seems to be compatible but when trying to migrate the
kafka producer I get an incompatibility error for the state migration.
It looks like the producer uses a list state of type
"NextTransactionalIdHint", but this class is specific for each Producer
FlinkKafkaProducer.NextTransactionalIdHint) and therefore the states are not
I would like to know what is the recommended way to perform this kind of
migration without losing the state ?
Thanks in advance,
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/