You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jk...@apache.org on 2015/04/05 01:06:16 UTC
kafka git commit: KAFKA-1996 Fix scaladoc error.
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 <zh...@gmail.com>
Authored: Sat Apr 4 16:05:45 2015 -0700
Committer: Jay Kreps <ja...@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)))