kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject kafka git commit: KAFKA-1996 Fix scaladoc error.
Date Sat, 04 Apr 2015 23:06:16 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 7acfa92c0 -> 9a071017e


KAFKA-1996 Fix scaladoc error.


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9a071017
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9a071017
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9a071017

Branch: refs/heads/trunk
Commit: 9a071017ee80331dc5b776e04ee2ed77f1d751db
Parents: 7acfa92
Author: Yaguo Zhou <zhouyaguo@gmail.com>
Authored: Sat Apr 4 16:05:45 2015 -0700
Committer: Jay Kreps <jay.kreps@gmail.com>
Committed: Sat Apr 4 16:05:45 2015 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/message/Message.scala | 2 +-
 core/src/main/scala/kafka/utils/Utils.scala     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/9a071017/core/src/main/scala/kafka/message/Message.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/message/Message.scala b/core/src/main/scala/kafka/message/Message.scala
index d302480..7ba280f 100644
--- a/core/src/main/scala/kafka/message/Message.scala
+++ b/core/src/main/scala/kafka/message/Message.scala
@@ -86,7 +86,7 @@ class Message(val buffer: ByteBuffer) {
   /**
    * A constructor to create a Message
    * @param bytes The payload of the message
-   * @param compressionCodec The compression codec used on the contents of the message (if
any)
+   * @param codec The compression codec used on the contents of the message (if any)
    * @param key The key of the message (null, if none)
    * @param payloadOffset The offset into the payload array used to extract payload
    * @param payloadSize The size of the payload to use

http://git-wip-us.apache.org/repos/asf/kafka/blob/9a071017/core/src/main/scala/kafka/utils/Utils.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/utils/Utils.scala b/core/src/main/scala/kafka/utils/Utils.scala
index 738c1af..894a6a6 100644
--- a/core/src/main/scala/kafka/utils/Utils.scala
+++ b/core/src/main/scala/kafka/utils/Utils.scala
@@ -220,7 +220,7 @@ object Utils extends Logging {
 
   /**
    * Recursively delete the list of files/directories and any subfiles (if any exist)
-   * @param a sequence of files to be deleted
+   * @param files sequence of files to be deleted
    */
   def rm(files: Seq[String]): Unit = files.map(f => rm(new File(f)))
 


Mime
View raw message