You will need to close the consume connector for it to be deregistered. However, normally, consumers in a group are not expected to change often.
Thanks, Jun On Wed, Oct 31, 2012 at 6:38 PM, Andrew Kellberg <akellb...@intelius.com>wrote: > 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 >
