tzulitai commented on issue #7979: [FLINK-11911] Make KafkaTopicPartition a valid POJO URL: https://github.com/apache/flink/pull/7979#issuecomment-472684022 @flinkbot disapprove consensus The main problem with this change is that this breaks state compatibility with previous savepoints. The `KafkaTopicPartition` is currently part of the state of `FlinkKafkaConsumer`. Changing that to be a POJO now, essentially means that we want to change its serializer from `KryoSerializer` (since the class was not identified as a POJO, Flink defaults to Kryo for its serialization) to a `PojoSerializer`. The essential change this requires in the serialization stack is that the `KryoSerializer` needs to be able to detect that the new serializer on restore is a `PojoSerializer`, and allows the change by first performing state schema migration. I suggest to address that first before coming back to this PR.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
