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
