dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1423029751
##########
core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala:
##########
@@ -190,4 +170,56 @@ class CoordinatorPartitionWriter[T](
throw Errors.NOT_LEADER_OR_FOLLOWER.exception()
}
}
+
+ /**
+ * Write the transaction end marker.
+ *
+ * @param tp The partition to write records to.
+ * @param marker The marker.
+ * @return The log end offset right after the written records.
+ * @throws KafkaException Any KafkaException caught during the write
operation.
+ */
+ override def completeTransaction(
Review Comment:
This adds a new method to the writer to write markers.
--
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
