You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jk...@apache.org on 2012/12/07 19:27:49 UTC
svn commit: r1418423 -
/kafka/branches/0.8/core/src/main/scala/kafka/message/Message.scala
Author: jkreps
Date: Fri Dec 7 18:27:48 2012
New Revision: 1418423
URL: http://svn.apache.org/viewvc?rev=1418423&view=rev
Log:
KAFKA-642 Missed message magic version on last checkin.
Modified:
kafka/branches/0.8/core/src/main/scala/kafka/message/Message.scala
Modified: kafka/branches/0.8/core/src/main/scala/kafka/message/Message.scala
URL: http://svn.apache.org/viewvc/kafka/branches/0.8/core/src/main/scala/kafka/message/Message.scala?rev=1418423&r1=1418422&r2=1418423&view=diff
==============================================================================
--- kafka/branches/0.8/core/src/main/scala/kafka/message/Message.scala (original)
+++ kafka/branches/0.8/core/src/main/scala/kafka/message/Message.scala Fri Dec 7 18:27:48 2012
@@ -51,7 +51,7 @@ object Message {
/**
* The current "magic" value
*/
- val CurrentMagicValue: Byte = 2
+ val CurrentMagicValue: Byte = 0
/**
* Specifies the mask for the compression code. 2 bits to hold the compression codec.