You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2014/10/23 23:52:14 UTC
git commit: kafka-1727; Fix comment about message format;
patched by Muneyuki Noguchi; reviewed by Jun Rao
Repository: kafka
Updated Branches:
refs/heads/trunk e8923ae33 -> cda1f73d0
kafka-1727; Fix comment about message format; patched by Muneyuki Noguchi; reviewed by Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cda1f73d
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/cda1f73d
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/cda1f73d
Branch: refs/heads/trunk
Commit: cda1f73d0498d66aafc8c6e57f84e0cd3c69928a
Parents: e8923ae
Author: Muneyuki Noguchi <no...@gmail.com>
Authored: Thu Oct 23 14:52:07 2014 -0700
Committer: Jun Rao <ju...@gmail.com>
Committed: Thu Oct 23 14:52:07 2014 -0700
----------------------------------------------------------------------
core/src/main/scala/kafka/message/Message.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/cda1f73d/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 d2a7293..d302480 100644
--- a/core/src/main/scala/kafka/message/Message.scala
+++ b/core/src/main/scala/kafka/message/Message.scala
@@ -70,7 +70,7 @@ object Message {
* A message. The format of an N byte message is the following:
*
* 1. 4 byte CRC32 of the message
- * 2. 1 byte "magic" identifier to allow format changes, value is 2 currently
+ * 2. 1 byte "magic" identifier to allow format changes, value is 0 currently
* 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