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 <jun...@gmail.com> Authored: Wed May 29 21:34:11 2013 -0700 Committer: Jun Rao <jun...@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) {
