Hi, 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 (FlinkKafkaProducer011.NextTransactionalIdHint vs FlinkKafkaProducer.NextTransactionalIdHint) and therefore the states are not compatible. I would like to know what is the recommended way to perform this kind of migration without losing the state ? Thanks in advance, Edward -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
