Kafka, mail # dev - Re: Troubles with compressed message set - 2013-01-30, 21:00
Solr & Elasticsearch trainings in New York & San Francisco [more info][hide]
 Search Hadoop and all its subprojects:

Switch to Plain View
David Arthur 2013-01-30, 15:27
Jay Kreps 2013-01-30, 16:19
Copy link to this message
Re: Troubles with compressed message set

Figured it out.

In Message.scala, CurrentMagicValue is set to 0; should be 2. This was
causing my client to attempt to decode it as a v0 message. Changing the
value to 2 solved my problem. Seems like a trivial change, so I'll let
you decided if you want a Jira or not.

 From my previous example,
should be 2


messages to set their offsets
On 1/30/13 11:18 AM, Jay Kreps wrote:
David Arthur 2013-01-30, 21:07
Jay Kreps 2013-01-30, 21:17
David Arthur 2013-01-30, 21:23
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB