tony810430 commented on issue #9824: [FLINK-14302] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS URL: https://github.com/apache/flink/pull/9824#issuecomment-539934547 @becketqin I have tried this [commit](https://github.com/tony810430/flink/commit/4f6473cdfda7e918075f21a61f961964301a2d5e) to simulate the case, but I failed to reproduce it on my local IDE. The leader indeed be migrated, but the exception didn't happen like I tried in the real kafka cluster. Did you know why? Since I couldn't get log message from TransactionCoordinator in embedded kafka cluster, I didn't know if `NOT_COORDINATOR` error really happened in broker.
---------------------------------------------------------------- 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
