kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [15/40] git commit: trivial change to fix incorrect comment in Message
Date Thu, 11 Jul 2013 06:37:25 GMT
trivial change to fix incorrect comment in Message


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

Branch: refs/heads/trunk
Commit: 492ed7a35d031b737b7c98dadcc8be777b9d2d57
Parents: 436dd25
Author: Jun Rao <junrao@gmail.com>
Authored: Wed May 29 21:34:11 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Wed May 29 21:34:11 2013 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/message/Message.scala | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/492ed7a3/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 12a8368..9b6eece 100644
--- a/core/src/main/scala/kafka/message/Message.scala
+++ b/core/src/main/scala/kafka/message/Message.scala
@@ -74,8 +74,9 @@ object Message {
  * 3. 1 byte "attributes" identifier to allow annotations on the message independent of the
version (e.g. compression enabled, type of codec used)
  * 4. 4 byte key length, containing length K
  * 5. K byte key
- * 6. (N - K - 10) byte payload
- * 
+ * 6. 4 byte payload length, containing length V
+ * 7. V byte payload
+ *
  * Default constructor wraps an existing ByteBuffer with the Message object with no change
to the contents.
  */
 class Message(val buffer: ByteBuffer) {


Mime
View raw message