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 <[email protected]> Authored: Thu Oct 23 14:52:07 2014 -0700 Committer: Jun Rao <[email protected]> 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
