From b5c0779874ea2ef1848220ffb1f792d18d6831da Mon Sep 17 00:00:00 2001 From: Yaguo Zhou Date: Mon, 2 Mar 2015 17:14:37 +0800 Subject: [PATCH] fix scala doc error: unknown tag parameter --- 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(-) 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 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))) -- 2.1.2