novosibman commented on code in PR #13782: URL: https://github.com/apache/kafka/pull/13782#discussion_r1223373702
########## storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManager.java: ########## @@ -430,11 +428,19 @@ public Optional<ProducerStateEntry> lastEntry(long producerId) { * Take a snapshot at the current end offset if one does not already exist. */ public void takeSnapshot() throws IOException { + takeSnapshot(null); + } + + /** + * Take a snapshot at the current end offset if one does not already exist. + * Flush the snapshot asynchronously if scheduler != null + */ + public void takeSnapshot(Scheduler scheduler) throws IOException { Review Comment: IOException still will be thrown on open/write/close operations. Force (flush) operation running by scheduler in a separate thread will write log warning only. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org