[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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
(FlinkKafkaProducer011.NextTransactionalIdHint  vs
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: