kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From va...@apache.org
Subject [kafka] branch trunk updated: fix typo (#5150)
Date Sat, 02 Feb 2019 23:15:54 GMT
This is an automated email from the ASF dual-hosted git repository.

vahid pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 4d70e89  fix typo (#5150)
4d70e89 is described below

commit 4d70e8971fb5f43021cd0d38630faa9ac23161a2
Author: lambdaliu <lambda.tencent@gmail.com>
AuthorDate: Sun Feb 3 07:15:42 2019 +0800

    fix typo (#5150)
---
 .../src/main/scala/kafka/coordinator/transaction/TransactionLog.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala b/core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala
index 2dc6e38..f74e8ad 100644
--- a/core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala
+++ b/core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala
@@ -29,13 +29,13 @@ import org.apache.kafka.common.record.CompressionType
 
 import scala.collection.mutable
 
-/*
+/**
  * Messages stored for the transaction topic represent the producer id and transactional
status of the corresponding
  * transactional id, which have versions for both the key and value fields. Key and value
  * versions are used to evolve the message formats:
  *
  * key version 0:               [transactionalId]
- *    -> value version 0:       [producer_id, producer_epoch, expire_timestamp, status,
[topic [partition], timestamp]
+ *    -> value version 0:       [producer_id, producer_epoch, expire_timestamp, status,
[topic, [partition] ], timestamp]
  */
 object TransactionLog {
 


Mime
View raw message