Мы хотим контролировать скорость, с которой потребитель может потреблять сообщения в HornetQ. Проблема в том, что когда мы используем метод ServerLocator.setConsumerMaxRate(int), мы всегда получаем 1 сообщение в секунду, независимо от передаваемого...

Я новичок в Java и работаю над проектом, который использует несколько (разных) тем и отправляет их на другой сервер. Мне было интересно, как лучше всего работать с несколькими темами. Насколько я понимаю, каждый потребитель привязан к одной теме,...

Мне было интересно, могу ли я зарегистрировать слушателя в MessageConsumer, а затем вызвать метод receive(). Я знаю, что это не похоже на практический сценарий, но было бы интересно узнать. Спецификация JMS допускает что-то подобное? Я знаю, что...

У меня есть кластер kafka, в котором есть 3 машины. И тема в которой 6 разделов(по 2 раздела на каждой машине). Когда я запускаю потребительское приложение, которое имеет 6 потребительских потоков и принадлежит к одной группе. Я знаю, что одному...

На машине CentOS работает сервер ActiveMQ. Я могу подключаться и получать сообщения по TCP и HTTP с помощью клиента OpenWire JMS. Однако, когда я попробовал использовать клиент STOMP для тестирования ActiveMQ, он выдает это исключение на...

Я хочу, чтобы потребитель kafka получал сообщения из определенного / указанного раздела темы Он работает с использованием kafka-console-consumer.sh с переключателем --partition partition_number Я использую код...