Joel,
Would you mind point me to how I would be able to enable the trace logs in
the producer and broker?
Thanks,
Scott
On Wed, Jul 10, 2013 at 5:33 PM, Joel Koshy jjkosh...@gmail.com wrote:
Weird - I tried your exact code and it worked for me (although I was
using 0.8 head and not the
Ok, the problem solved, I think it might be because some of the jar files
that I was using were OLD. I was building the producer and consumer
under the 0.7 environment except swapping out the kafka jar file. Now, I
created a whole new environment and pull in all the jar files from the
0.8.
Jun,
I did a test this morning and got a very interesting result with you
command. I started by wipe all the log files and clean up all zookeeper
data files.
Once I restarted both server, producer and consumer then execute your
command, what I got is a empty log as following:
Dumping
Weird - I tried your exact code and it worked for me (although I was
using 0.8 head and not the beta). Can you re-run with trace logs
enabled in your producer and paste that output? Broker logs also if
you can?
Thanks,
Joel
On Wed, Jul 10, 2013 at 10:23 AM, Scott Wang
Another piece of information, the snappy compression also does not work.
Thanks,
Scott
On Tue, Jul 9, 2013 at 11:07 AM, Scott Wang
scott.w...@rumbleentertainment.com wrote:
I just try it and it still not showing up, thanks for looking into this.
Thanks,
Scott
On Tue, Jul 9, 2013 at
No, I did not start the consumer before the producer. I actually started
the producer first and nothing showed up in the consumer unless I commented
out this line -- props.put(compression.codec, gzip).If I commented
out the compression codec, everything just works.
On Mon, Jul 8, 2013 at
