flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] [flink] pnowojski commented on a change in pull request #7930: [FLINK-11249][kafka] Fix migration from FlinkKafkaProducer0.11 to universal
Date Wed, 29 May 2019 07:27:41 GMT
pnowojski commented on a change in pull request #7930: [FLINK-11249][kafka] Fix migration from
FlinkKafkaProducer0.11 to universal
URL: https://github.com/apache/flink/pull/7930#discussion_r288422975
 
 

 ##########
 File path: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
 ##########
 @@ -174,10 +174,16 @@
 
 	/**
 	 * Descriptor of the transactional IDs list.
+	 * Note: This state is serialized by Kryo Serializer and it has compatibility problem that
will be removed later.
 
 Review comment:
   We do not have any specific plans. We were waiting to make sure that universal connector
is stable and we also need to solve the migration story from `0.11` to the `universal` connector
(this PR). So if everything goes well and there won't be any issues with the migration, the
soonest we could remove `0.11` connector is `1.10` release.
   
   However I'm hardly an expert in this regard (maintaining public APIs) and I think it's
better to coordinate those plans with @aljoscha or @tzulitai .

----------------------------------------------------------------
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:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message