Hello,
I have two consumers running (on different hosts), trying to consume messages
from a single topic, but only one of them receives messages.
Here's how my consumer is configured:
consumer = new DefaultMQPushConsumer("my_consumer_group")
consumer.setNamesrvAddr(nameServers)
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET)
consumer.setMessageModel(MessageModel.CLUSTERING)
consumer.subscribe("my_topic", "*")
consumer.registerMessageListener(new MessageListenerConcurrently {
...
})
The configuration is identical on all consumers.
Is there some configuration on the topic that needs to be done so that the
messages are load-balanced evenly between the consumers?
Thanks,
Adam
--
Adam Warski
http://www.softwaremill.com
http://twitter.com/#!/adamwarski
