yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-454378135
Agree @pnowojski , this PR needs to be tested and verified. After merging,
we could confirm that it is the
yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-454321088
@cjolif Sorry, I haven't started writing tests yet, but considering that you
are very dependent on this PR,
yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-453031536
@pnowojski Just make sure that shall I implement a Class named for example
yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-452662950
@pnowojski OK, I will implement the migrations tests in a separate commit
soon.
yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-451621417
@pnowojski Can you help me to confirm that this state of migration is
correct? After getting your
yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-451369403
cc @pnowojski and @aljoscha
This is an