[GitHub] tzulitai edited a comment on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

[GitBox <gi...@apache.org>]

tzulitai edited a comment on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-452623432
 
 
   @yanghua @pnowojski I took a look, so from my understanding, the migration that we're trying to perform here is:
   Switch from using the Flink-determined serializer to a custom state serializer for the `NextTransactionalIdHint` class.
   
   Looking at the `NextTransactionalClass`, I think the `KryoSerializer` will be used to serialize that (it doesn't qualify as a POJO).
   
   Short answer: as of the current master this isn't possible yet, so the only way to do that is the "old-school" way for this specific case.
   
   Longer answer:
   While this is theoretically possible with the new state migration feature, the problem is that the `KryoSerializer` has not yet been updated to use the new serializer abstractions that is required to support state schema evolution. Only a few serializers, most notably the `AvroSerializer` had been updated in 1.7.x.
   
   Good news is, we're planning to fully update all Flink-shipped serializers to use the new abstractions for 1.8.
   
   So, while you may only be able to do it the old-school way for now with the current master, things should change by the time we decide to release 1.8.
   I suggest that we proceed with the current solution, but open a JIRA ticket to keep this tracked for 1.8.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services