tzulitai commented on PR #52: URL: https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1755995458
@Tan-JiaLiang ok - lets try to reach consensus here. It does seem like that my approach can lead to other problems, e.g. bombarding Kafka brokers from multiple end-offset lookups across multiple TMs. This might turn out worse than doing just one more extra query on the JM. And since JMs right already are assumed to have access to Kafka brokers already anyways, we should be breaking anything for users. So overall - lets proceed with this PR's approach. Sorry for the back and forth @Tan-JiaLiang, just wanted to make sure that we're fixing this properly. Regarding the restore issue you mentioned: yes, please address that, and then I think we can merge this. -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
