These are not really errors, but info from ZK client lib.

Thanks,

Jun

On Thu, Nov 1, 2012 at 10:25 AM, Andrew Kellberg <[email protected]>wrote:

> 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
>

Reply via email to