jolshan commented on code in PR #15486: URL: https://github.com/apache/kafka/pull/15486#discussion_r1526868437
########## core/src/main/scala/kafka/server/ReplicaManager.scala: ########## @@ -975,12 +978,13 @@ class ReplicaManager(val config: KafkaConfig, /** * - * @param topicPartition the topic partition to maybe verify - * @param transactionalId the transactional id for the transaction - * @param producerId the producer id for the producer writing to the transaction - * @param producerEpoch the epoch of the producer writing to the transaction - * @param baseSequence the base sequence of the first record in the batch we are trying to append - * @param callback the method to execute once the verification is either completed or returns an error + * @param topicPartition the topic partition to maybe verify + * @param transactionalId the transactional id for the transaction + * @param producerId the producer id for the producer writing to the transaction + * @param producerEpoch the epoch of the producer writing to the transaction + * @param baseSequence the base sequence of the first record in the batch we are trying to append + * @param callback the method to execute once the verification is either completed or returns an error + * @param partitionOperation the enum value which determines whether the client is ready to handle the new Abortable Txn Errors Review Comment: nit: to make this more generic we should say something like "determines which version of the client sent the request so the addPartitionsToTxnManager handles it appropriately". I also wonder if we want to rename the argument. PartitionOperation is a little unclear. -- 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