Tan-JiaLiang commented on PR #52: URL: https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1757025277
@tzulitai I found it difficult to get the end-offset and set into the state when TMs restore. Because of this problem doesn't come up very often and once the partition fetch records, that will not a problem. So i would like to still call the `seekToEnd` API when currentOffset is -1 to compatibility with the history state. I rollback the `KafkaPartitionSplitReader` changes and refine the test case, can you please have a look? Let's finish it in this week. -- 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
