Corrupted message in master partition, but valid in replica

Hi, I see issue in kafka 0.9 consumer where messages are corrupted in partitions master node . I have details explained in stack-overflow . http://stackoverflow.com/questions/43379306/kafka-message-corrupted-in-master-but-replica-looks-good . Can someone help ? --Dhyan

Kafka 0.9-Java : consumer skipping offsets during application restart

Hi, Can some one look at the below question and see if you can help ? I've tried to explain the issue in stack overflow . http://stackoverflow.com/q/41177614/3705186 --Dhyan

Re: Good java consumer example with new 0.9 consumer api

Thank you .These docs are good .Thanks for your help . —Dhyan > On Dec 6, 2015, at 6:54 AM, jinxing wrote: > > You can refer: > http://people.apache.org/~nehanarkhede/kafka-0.9-consumer-javadoc/doc/ > > > > > > > > At 2015-12-06 08:41:24, "

Good java consumer example with new 0.9 consumer api

Hi All, Can some one point me good java Consumer that uses 0.9 new consumer API . I searched in github and couldn’t find one . —Dhyan

Re: Kafka 0.8.2.1 - how to read from __consumer_offsets topic?

I have this same problem . Can someone help ? --Dhyan On Wed, Nov 25, 2015 at 3:31 PM, Marina wrote: > Hello, > > I'm trying to find out which offsets my current High-Level consumers are > working off. I use Kafka 0.8.2.1, with **no** "offset.storage" set in the > server.properties of Kafka - w