Here's the errors that are getting generated when I run my Consumer Service calls:
[2012-10-31 18:39:26,418] INFO Got user-level KeeperException when processing sessionid:0x13ab993cbdc0021 type:create cxid:0x15 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/consumers/e293697c-37fd-4b55-99f7-fa0e99d39b77/owners Error:KeeperErrorCode = NoNode for /consumers/e293697c-37fd-4b55-99f7-fa0e99d39b77/owners (org.apache.zookeeper.server.PrepRequestProcessor) [2012-10-31 18:39:36,386] INFO Got user-level KeeperException when processing sessionid:0x13ab993cbdc0021 type:setData cxid:0x19 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/consumers/e293697c-37fd-4b55-99f7-fa0e99d39b77/offsets/100103_truerep/0-0 Error:KeeperErrorCode = NoNode for /consumers/e293697c-37fd-4b55-99f7-fa0e99d39b77/offsets/100103_truerep/0-0 (org.apache.zookeeper.server.PrepRequestProcessor) From: Andrew Kellberg Sent: Wednesday, October 31, 2012 6:39 PM To: '[email protected]' Subject: Consumer not registering as no longer active Hi, What I am trying to do is create a Consumer Java Service where you can send a request to the Java Service asking for say 15 messages for a topic, then if 15 messages were returned we assume there are, so then another request is sent to the Java Service and the next 15 messages in the topic are returned. Each request has the same Consumer Group. The problem I am running into is that the first request returns 15 messages and then subsequent requests return nothing. If make the consume group id different each time I get messages, but it keeps consuming the same message and runs forever. It seems like the problem is that the first Consumer's Consumer ID becomes the owner for the topic on the broker so when I make subsequent calls to my Java Service a new Consumer is created with a new Consumer ID and no messages are consumed. I am calling the shutdown method for my consumer after it consumes the 15 messages. Is there anything more I need to do so the broker recognizes that Consumer ID is no longer active? Any help would be greatly appreciated. Thanks, Andrew
