Re: Create topic, then fetch offset

2015-01-14 Thread Henri Pihkala
est fails. Can >>>> anyone explain why? >>>> >>>> https://gist.github.com/hpihkala/f93ef3dc4c08382df69e >>>> <https://gist.github.com/hpihkala/f93ef3dc4c08382df69e> >>>> >>>> Best regards >>>> Henri

Re: Create topic, then fetch offset

2015-01-13 Thread Henri Pihkala
OffsetRequest is used for retrieving the last committed offset of a > certain consumer group; for your use case you would send OffsetRequest. > > That said the error code is misleading, it may be a bug in not indicating > the right error code. > > Guozhang > > > On Fri

Create topic, then fetch offset

2015-01-09 Thread Henri Pihkala
(1) Create topic (2) Send a FetchOffsetRequest for a partition in the new topic Results in error code 3, or UnknownTopicOrPartition. How can it be unknown, since I just created it? Shouldn’t it return 0, as that’s the offset of the next (first) message? Is this a bug or a feature? Tried with b

Topic in bad state after controller to broker messaging fails

2015-01-06 Thread Henri Pihkala
Hi, I’m hitting a strange problem using 0.8.2-beta and just a single kafka broker on CentOS 6.5. A percentage of my topic create attempts are randomly failing and leaving the new topic in a state in which it can not be used due to “partition doesn’t exist” errors as seen in server.log below.