abbccdda commented on a change in pull request #8900: URL: https://github.com/apache/kafka/pull/8900#discussion_r443855731
########## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java ########## @@ -250,10 +250,26 @@ public void flush() { * @throws TaskMigratedException recoverable error that would cause the task to be removed */ @Override - public void close() { - log.info("Closing record collector"); + public void closeClean() { + log.info("Closing record collector clean"); + + // No need to abort transaction during a clean close: either we have successfully committed the ongoing + // transaction during handleRevocation and thus there is no transaction in flight, or else none of the revoked + // tasks had any data in the current transaction and therefore there is no need to commit or abort it Review comment: nit: period at the end ########## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java ########## @@ -250,10 +250,26 @@ public void flush() { * @throws TaskMigratedException recoverable error that would cause the task to be removed */ @Override - public void close() { - log.info("Closing record collector"); + public void closeClean() { + log.info("Closing record collector clean"); + + // No need to abort transaction during a clean close: either we have successfully committed the ongoing Review comment: nit: clean close ---------------------------------------------------------------- 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: us...@infra.apache.org