kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: MINOR: documentation fix in StringDecoder
Date Fri, 07 Aug 2015 23:10:32 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 47c99f387 -> a36befd81


MINOR: documentation fix in StringDecoder

Author: Dave Cromberge <davecromberge@gmail.com>

Closes #124 from davecromberge/documentation-fix and squashes the following commits:

7b9b1ce [Dave Cromberge] minor documentation fix to StringDecoder


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

Branch: refs/heads/trunk
Commit: a36befd81ed97c18e3e676559617bffdbb191d65
Parents: 47c99f3
Author: Dave Cromberge <davecromberge@gmail.com>
Authored: Fri Aug 7 16:10:25 2015 -0700
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Fri Aug 7 16:10:25 2015 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/serializer/Decoder.scala | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/a36befd8/core/src/main/scala/kafka/serializer/Decoder.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/serializer/Decoder.scala b/core/src/main/scala/kafka/serializer/Decoder.scala
index 54d0b93..164c3fa 100644
--- a/core/src/main/scala/kafka/serializer/Decoder.scala
+++ b/core/src/main/scala/kafka/serializer/Decoder.scala
@@ -5,7 +5,7 @@
  * The ASF licenses this file to You under the Apache License, Version 2.0
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
- * 
+ *
  *    http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
@@ -36,16 +36,16 @@ class DefaultDecoder(props: VerifiableProperties = null) extends Decoder[Array[B
 }
 
 /**
- * The string encoder translates strings into bytes. It uses UTF8 by default but takes
+ * The string decoder translates bytes into strings. It uses UTF8 by default but takes
  * an optional property serializer.encoding to control this.
  */
 class StringDecoder(props: VerifiableProperties = null) extends Decoder[String] {
-  val encoding = 
+  val encoding =
     if(props == null)
-      "UTF8" 
+      "UTF8"
     else
       props.getString("serializer.encoding", "UTF8")
-      
+
   def fromBytes(bytes: Array[Byte]): String = {
     new String(bytes, encoding)
   }


Mime
View raw message