kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fix doc - `FileMessageSet` was replaced by `FileRecords` (#4852)
Date Wed, 11 Apr 2018 21:27:10 GMT
This is an automated email from the ASF dual-hosted git repository.

jgus 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 83a9e04  MINOR: Fix doc - `FileMessageSet` was replaced by `FileRecords` (#4852)
83a9e04 is described below

commit 83a9e04c1975f9e0fcfe41f5084a43353592b340
Author: Jimin Hsieh <jimin.hsieh.engineer@gmail.com>
AuthorDate: Thu Apr 12 05:27:04 2018 +0800

    MINOR: Fix doc - `FileMessageSet` was replaced by `FileRecords` (#4852)
    
    Reviewers: Manikumar Reddy O <manikumar.reddy@gmail.com>, Jason Gustafson <jason@confluent.io>
---
 core/src/main/scala/kafka/log/LogSegment.scala | 4 ++--
 core/src/main/scala/kafka/log/package.html     | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/core/src/main/scala/kafka/log/LogSegment.scala b/core/src/main/scala/kafka/log/LogSegment.scala
index 5130b28..5f5f3736 100755
--- a/core/src/main/scala/kafka/log/LogSegment.scala
+++ b/core/src/main/scala/kafka/log/LogSegment.scala
@@ -34,14 +34,14 @@ import scala.collection.JavaConverters._
 import scala.math._
 
 /**
- * A segment of the log. Each segment has two components: a log and an index. The log is
a FileMessageSet containing
+ * A segment of the log. Each segment has two components: a log and an index. The log is
a FileRecords containing
  * the actual messages. The index is an OffsetIndex that maps from logical offsets to physical
file positions. Each
  * segment has a base offset which is an offset <= the least offset of any message in
this segment and > any offset in
  * any previous segment.
  *
  * A segment with a base offset of [base_offset] would be stored in two files, a [base_offset].index
and a [base_offset].log file.
  *
- * @param log The message set containing log entries
+ * @param log The file records containing log entries
  * @param offsetIndex The offset index
  * @param timeIndex The timestamp index
  * @param baseOffset A lower bound on the offsets in this segment
diff --git a/core/src/main/scala/kafka/log/package.html b/core/src/main/scala/kafka/log/package.html
index c6ebf0c..ee2f72e 100644
--- a/core/src/main/scala/kafka/log/package.html
+++ b/core/src/main/scala/kafka/log/package.html
@@ -21,4 +21,4 @@ The log management system for Kafka.
 The entry point for this system is LogManager. LogManager is responsible for holding all
the logs, and handing them out by topic/partition. It also handles the enforcement of the
 flush policy and retention policies.
 
-The Log itself is made up of log segments. A log is a FileMessageSet that contains the data
and an OffsetIndex that supports reads by offset on the log.
\ No newline at end of file
+The Log itself is made up of log segments. A log is a FileRecords that contains the data
and an OffsetIndex that supports reads by offset on the log.
\ No newline at end of file

-- 
To stop receiving notification emails like this one, please contact
jgus@apache.org.

Mime
View raw message