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:
[email protected]
