开发者社区> 问答> 正文

rocketmq发送消息报错——not exist, apply first please

确定broker连上了nameserver,消费者没连上nameserver,请问如何解决 报错信息——

org.apache.rocketmq.client.exception.MQBrokerException: CODE: 17  DESC: topic[order-group] not exist, apply first please!

消费者设置

DefaultMQProducer producer = new DefaultMQProducer("order-group");
        producer.setNamesrvAddr("127.0.0.1:9876");
        producer.setCreateTopicKey("order-topic");
        producer.setSendMessageWithVIPChannel(false);
        producer.setInstanceName(System.currentTimeMillis()+"");
        producer.start();
        System.out.println(producer.getCreateTopicKey());

展开
收起
游客x6vj2wvqljltm 2020-12-15 11:00:22 3605 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
RocketMQ Client-GO 介绍 立即下载
RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载