Re: Create topic, then fetch offset

2015-01-14 Thread Henri Pihkala
/test_d5ee7dfe-cf33-4135-9bbd-c1e7d9367af2 ��t${version:1,partitions:{0:[0]}} cZxid = 0x2ea0 ctime = Tue Jan 13 16:08:19 PST 2015 mZxid = 0x2ea0 mtime = Tue Jan 13 16:08:19 PST 2015 On Tue, Jan 13, 2015, at 02:28 PM, Henri Pihkala wrote: Hi, Thanks for your reply, Guozhang, you are right. I

Re: Create topic, then fetch offset

2015-01-13 Thread Henri Pihkala
, FetchOffsetRequest 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, Jan 9, 2015 at 4:10 AM, Henri Pihkala

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.