becketqin 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_r287733153
##########
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:
Do we have a plan to deprecate 0.11? This class share a lot of code with
FlinkKafkaProducer. After Kafka 0.10.2, the clients can actually talk to any
broker at 0.10+. So it may not necessary to keep 0.11 clients anymore. This
will help remove quite some duplicate code.
----------------------------------------------------------------
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:
[email protected]
With regards,
Apache Git Services
