Параллельная отправка сообщения брокеру RocketMQ, вызывающему исключение
Мой производитель Rocket MQ отправляет 500 сообщений параллельно 500 темам. Но время отправки сообщения для некоторых тем вызывает исключение: "Нет информации о маршруте для этой темы". Но тема уже создана. Я проверил это в файле themes.json, а также в консоли RocketMQ. Сначала я создаю темы:
_producer.createTopic(DEFAULT_TOPIC, topicName, 4);
тогда я отправляю сообщения:
Message msg = new Message(topicName, "TagA", "key01", data);
MessageQueueSelector qs = new QueueSelector();
_producer.send(msg, qs, 0);
Я не понимаю причину этого. Есть ли решение проблемы параллельной отправки сообщений в брокере RocketMQ?