Do you have any errors in the logs? Are you using a partition key or is your KeyedMessage just topic and message? If your not using a partition key then then take a look at this https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Whyisdatanotevenlydistributedamongpartitionswhenapartitioningkeyisnotspecified ?
You can try using https://github.com/edenhill/kafkacat which is an stdout/stdin producer/consumer command line tool for kafka. And then you can do echo "test"|kafakcat -b yourKafkaBroker -t xxxx -p 0 echo "test"|kafakcat -b yourKafkaBroker -t xxxx -p 1 and see if it works trying to explicitly write to both partitions, if that works then see above and if it doesn't work then you should get an error. /******************************************* Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> ********************************************/ On Wed, Oct 1, 2014 at 7:31 AM, Jacky <jiang0...@gmail.com> wrote: > Anyone has idea? Thank you > > Sent from my iPhone > > > On Sep 30, 2014, at 1:45 PM, Jiang Jacky <jiang0...@gmail.com> wrote: > > > > Hi, Guys > > It is very weird, I created a topic with 2 partitions couple weeks ago, > and I can only production the message to partition 0, not partition 1, but > for now, I created a new topic again with 2 partitions, it does work. > > So whats problem of the old topic? I tried to describe the old topic, I > found the following message > > > > Topic: xxxx Partition: 0 Leader: 1 Replicas: 1 > Isr: 1 > > Topic: xxxx Partition: 1 Leader: 2 Replicas: 2 > Isr: 2 > > > > Please let me know, if the topic is screwed up. > > > > Thank you > > > > >
