rocketmq无法创建Topic

问题如下:
在启动namesrv、 broker后,创建Topic一直出现如下的问题,没有找到解决方法
[root@localhost bin]# sh mqadmin updateTopic ‐c DEFAULT_CLUSTER ‐n 192.168.202.128:9876 ‐t TopicTest1 ‐r 10 ‐w 10
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
usage: mqadmin updateTopic [-b ] [-c ] [-h] [-n ] [-o ] [-p ] [-r ] [-s ]
-t [-u ] [-w ]
-b,--brokerAddr create topic to which broker
-c,--clusterName create topic to which cluster
-h,--help Print help
-n,--namesrvAddr Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
-o,--order set topic's order(true|false
-p,--perm set topic's permission(2|4|6), intro[2:W 4:R; 6:RW]
-r,--readQueueNums set read queue nums
-s,--hasUnitSub has unit sub (true|false
-t,--topic topic name
-u,--unit is unit topic (true|false
-w,--writeQueueNums set write queue nums

0

1个回答

需要指定broker地址 加上-b localhost:10911这样的参数

0
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
rocketmq 自动创建topic的过程分析以及为什么自动创建topic可能会导致负载不均衡的情况
昨天在rocketmq官方钉钉群里面看到了一个人发了如下问题,没人解答,发现自己之前阅读过相关源码。给予了回复。记录下来nnnnclient本地首先没有缓存对应topic的路由信息,然后先去nameserver去查找,nameserver中也没有此topic的路由信息,然后返回给client。client接收到返回后再向nameserver请求topic为tbw102的路由信息。如果有broker...
RocketMQ通过命令行创建Topic
nnupdateTopic命令很多人都知道,也在博客上复制粘贴了官网的。但很多人没有给出具体的简单例子,对于初学者而言要的就是直观的例子,可以拷贝下来改个数字直接使用的例子。文档大家都知道看,但很多人看了还是不知道具体怎么去做。因为官网只是给一个介绍。具体命令怎么使用需要靠自己摸索。nnupdateTopic命令主要是三个参数:nn-b broker_id:broker_port  ,ip都知道就...
Rocketmq topic 管理及自动创建分析
rocketmq topic 信息是保存在broker 上nnborker会定期保存到store/config 下topics.jsonn每次broker启动会默认创建系统级topic,其中就有TBW102,此topic的route(配置)将作为sendmessage时候未创建topic的默认routen禁止自动创建topic方法:修改TBW102 PERM为0并且需要注意每个新broker增加的...
RocketMQ——从NameServer更新客户端订阅的topic路由信息
由Producer或Consumer端调用MQClientInstance. updateTopicRouteInfoFromNameServer()方法的目的主要有:1)从NameServer获取该客户端订阅的每个topic的相关信息(包括每个topic对应的Broker信息和topic配置信息),用TopicRouteData对象表示;并将该对象信息存入MQClientInstance.topi
RocketMQ集群-主题创建及队列分布
先了解集群是怎么搭建的,再了解主题在集群上的创建过程以及队列分布状态。n搭建集群n这里讨论主备和多主,暂不讨论多主备n1. 主备nmaster主要配置nbrokerClusterName = DefaultClusternbrokerName = broker-anbrokerId = 0nbrokerRole = ASYNC_MASTERnnslave主要配置nbrokerClusterName...
rocketmq:订阅组和消费组的关系。
之前在没看过源码之前对于 订阅组和消费组没有一个清楚的认知。nn今天就来分析下两者的关系。nn订阅组:订阅组的创建是依赖于消费组的创建。从订阅组的创建运维命令可以发现。有3个参数是必填(cluster和broker选填一个,最佳实践肯定是选择把cluster给填了), -n和-c或者-b肯定不用说的,nameserver地址和cluster名称或者broker地址肯定是要填上的,因为在cluste...
RocketMQ常用命令使用示例及说明
1. 前言nn本文主要为RocketMQ的大部分客户端运维命令的基本使用示例,文中使用的参数为最少必须参数,相关参数会有简单介绍。nn本文说明的命令基于RocketMQ的3.5.8版本,有些命令可能在更低版本中并不存在。nn运维命令脚本放在bin目录下。nn本文使用的测试集群为2m-noslave集群。nn笔者会尽量把大部分的命令举例说明,但是每个命令的具体参数说明,请通过--help查看或者查阅...
rocketmq 消费者负载均衡-分布式下的messageQueue的分配和锁定
思考一个问题,分布式环境,网络不稳定.na台broker上有messageQueue,b台queue.na,b都会随着网络不稳定而变动,你如何分配,并且保证messageQueue都被分配出去.nrocketMq实现: 客户端实现负载均衡,每个人的算法都一样. (源自于大家都从zk上获取, topic总messageQueue和consumers )n然后平均分配. 有可能因为某些原因,得
rocketmq的client版本和服务端版本不一样的话,不能新增topic
这是个深坑。。。。nn执行到这到时候,点进去看:n4.4.0版本nn而4.3.0版本nn奇坑无比。。。nn
RocketMQ概念模型
RocketMQ概念模型n一 前言n  对于任何一款中间件产品而言,清晰的概念模型是帮助用户正确理解使用它的关键。由于RocketMQ并没有遵循业界现有的JMS或AMQP规范,而且功能集比后两者更加丰富,描述该中间件产品的概念模型是一项比较有挑战的任务。RocketMQ的官方文档《RocketMQ 原理简介》对产品的概念模型给出了比较简洁而清晰的介绍。n  本文将针对用户在使用RocketM
rocketmq问题汇总-一个consumerGroup只对应一个topic
1 同一个订阅组内不同Consumer实例订阅不同topic消费混乱问题调查nn图1:nnnn背景说明:nn如图1左半部分,假设目前的关系如下:nnbroker: 两个,broker_a和broker_bnntopic:两个,topic1和topic2,每个topic在每个broker上分为4个queuennconsumer:两个,consumer1和consumer2
RocketMQ——Producer篇:其他功能介绍
1 向Broker发送心跳消息1、初始化HeartbeatData对象,将该Producer或Consumer的ClientID赋值给HeartbeatData对象的clientID变量;2、遍历MQClientInstance.consumerTable: ConcurrentHashMap<String/* group */, MQConsumerInner>变量,根据每个MQConsumer
在Windows上搭建RocketMQ的流程和注意事项
由于需要在本地开发RocketMQ,于是在windows环境下搭建了一套RocketMQ的环境,记下来搭建的流程和注意的问题。n一,在github上下载RocketMQ的项目ngithub的地址是:https://github.com/alibaba/RocketMQ/releasesn我选择的是3.2.6的版本,页面上是这样的:nnn在Downloads那一栏有下载项,其中Sourc
RocketMQ入门(2.快速入门)
本文档主要包含以下内容:nn如何开通 MQ 服务如何申请 MQ 资源如何通过 MQ 进行消息收发nMQn 快速接入流程图:nnnnnn1.开通MQ服务n在阿里云官方网站开通MQ服务。nnn2.申请MQ资源n在 MQ 消息系统中,消息发布者将消息发送到某个指定的消息主题(Topic) ,而消息订阅者则通过订阅该指定的 Topic 来获取和消费消息。因此一个新的应用接入
RocketMQ基本概念及原理介绍
n基本概念ProducerGroup通常具有同样属性(处理的消息种类-topic、以及消息处理逻辑流程—分布式多个客户端)的一些producer可以归为同一个group。在事务消息机制中,如果某条发送某条消息的producer-A宕机,使得事务消息一直处于PREPARED状态并超时,则broker会回查 同一个group的其他producer,确认这条消息应该commit还是rollback。Co...
RocketMQ路由错误
n如果报com.alibaba.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest1See https://github.com/alibaba/RocketMQ/issues/264 for further details.at com.alibaba.rocketmq.clien...
RocketMQ中的message queue是个什么,该怎么理解?
RocketMQ中的message queue是个什么,该怎么理解? n1. Topic, internally, is logically partitioned into one or more sub-topics. We call these sub-topics “message queues”. This concept plays a major role in implementin
RocketMQ中的生产者组只能有一个在用的生产者:
RocketMQ中的生产者组只能有一个在用的生产者: nWarning: Considering the provided producer is sufficiently powerful at sending messages, only one instance is allowed per producer group and process to avoid unnecessarily i
关于rocketmq不能消费的问题
项目使用了消息中间件rocketmq,用于两个关联项目之间的通信,先前消费者一直是可以消费的,突然有一天消费者消费不到数据了,解决过程mark一下,1,怀疑是不是生产者出问题了,没有生产数据。和生产者那边联系了一下,那边回复说一直有生产数据的,排除2,怀疑是不是什么配置有问题,导致不能消费。仔细检查了下,消费者组、topic、tag、地址、端口和生产者那边沟通了一下,发现这些东西也都没问题。排除3...
RocketMQ实战(二)之可视化管理控制台rocketmq-console的搭建
官方提供了一个WEB项目,可以查看rocketmq数据和执行一些操作。incubator-rocketmq-externals,这个项目中有一个子模块叫“rocketmq-console”,这个便是管理控制台项目。nn具体步骤如下:nngithub网址为:https://github.com/apache/rocketmq-externalsnnnn将项目通过git下载至本地nnnn下载到本地的i...
RocketMQ使用之发送消息分析(四)
前言nn这篇文章还有一个疑问没解决,查了很多资料,源码也翻了好几遍还是没找出nnn Topic路由信息如果本地没获取到从NameSer获取缓存nnn为什么NameSer会有,它的路由信息是从哪里来的?为什么NameSer一定能获取到,因为所有的相关博客中都没考虑获取不到的情况。有点点猜想。我们在初始化Producer时和NameSer建立长连接,这其中在发送消息时是不是发生了什么事?nn所以这里...
RocketMQ 的基础与规范
在公司里边,负责消息中间件这块工作,也进行了内部知识的交流。但效果不太明显呀!今天把一些 Rocketmq 的重要的知识点整理出来!nProducer n 消息生产者,负责产生消息,一般由业务系统负责产生消息。nConsumer n 消息消费者,负责消费消息,一般是后台系统负责异步消费。拉取后的消息,是放在线程池里面的。nPull Consumer n Consumer 的一种,应用通常竹筒调用
RocketMQ简单入门实例
消息队列优势专业&amp;amp;验证MQ是消息领域业内专业的消息中间件,多次在国内外获奖经过双11阿里交易、商品、营销等核心链路真实场景验证阿里集团内部1000+核心应用使用,每天流转几千亿条消息,稳定可靠3种消息发送方式,消息场景全覆盖:可靠同步、可靠异步、oneway方式技术体系产品历史超过7年,消息保证不丢,技术体系丰富成熟阿里内部产品名:MetaQ、Notify开源社区产品名:RocketMQ,...
淘宝消息中间件RocketMQ的安装和简单使用
[b]rnRocketMQ是什么?rnRocketMQ是一款分布式、队列模型的消息中间件,具有以下特点:rn能够保证严格的消息顺序rn提供丰富的消息拉取模式rn高效的订阅者水平扩展能力rn实时的消息订阅机制rn亿级消息堆积能力rnRocketMQ是alibaba开源的java消息中间件。在github上开源,项目同时也在oschina上。地址:https://git.oschina.net/vin...
RocketMQ篇.Topic配置中perm的含义
作用: 设置该 Topic 的读写模式。n取值说明如下:n6:同时支持读写n4:禁写n2:禁读nn一般情况设置为: 6nn
手动创建rocketmq中的topic
对于一些经常使用mq的项目,开发在提测后经常会出现mq的topic不能自动创建,让其找原因,也找不出个所以然来,这时便会影响后面测试进度,那么我们可以手动创建topic。n命令:sh mqadmin updatetopic -n mq服务器所在地址 -c 进群组名 -t topic名字nn查看进群组名:n1.ps -ef|grep rocketmq 查看用的是哪个配置项nn2. vim...
rocketmq学习笔记 六 流程之发消息
前面走马观花的看了一些源码,动手操作了一些例子。n虽然轮廓有了,但是细节还需研究。接下来研究流程nnn@startumlntitle 发消息流程n==启动流程==nactor producernproducer->DefaultMQProducer:startnactivate DefaultMQProducernDefaultMQProducer->DefaultMQProd
RocketMQ-记RocketMQ启动后producer无法连接到broker的错误及解决方案
nnn背景n排查n解决方案n总结n参考nnnnnnnn背景nn最近在学习RocketMQ,第一步就是安装部署并启动RocketMQ.使用最新版本的RocketMQ,版本为4.2.0,安装后启动相关服务. n启动nameServer:nnnohup mqnamesrv &amp;amp;amp;amp;amp;amp;amp;amp;amp;nn由于broker和nameServer在同一台机器上,启动broker:nnnnnohup mqbroker -n l...
RocketMQ4.2.0-参数配置解析- MQAdmin命令参数大全
名称选项必填参数含义UpdateTopicSubCommandupdateTopic:Update or create topic pFALSEpermset topic's permission(2|4|6), intro[2:W 4:R; 6:RW]bFALSEbrokerAddrcreate topic to which brokerrFALSEreadQueueNumsset read q...
RocketMQ源码分析----发送消息
主要步骤nn发送消息的主要流程总结如下步骤:nn1.获取Topic信息TopicPublishInfo:tryToFindTopicPublishInfonnnnna) 从缓存map topicPublishInfoTable中获取nnnnb) 空则新建nnnnc) 更新topic信息:updateTopicRouteInfoFromNameServer
八、rabbbitMQ主题模式 (Topic)
1.模型解读:Topic Exchange 将路由键和某模式进行匹配# 匹配一个或多个* 匹配一个2.实例开发(1)生产者import java.io.IOException;import java.util.concurrent.TimeoutException;import com.demo.rabbitMQ.util.ConnectionUtils;import com.rabbitmq.c...
RocketMQ——Producer篇:发送普通消息
以DefaultMQProducer.send(Message msg)方法为例,讲解Producer消息的发送逻辑,该方法最终调用DefaultMQProducerImpl.sendDefaultImpl(Message msg, CommunicationMode communicationMode, SendCallback sendCallback, long timeout)方法完成消息的
RocketMQ详解(4)——入门程序
RocketMQ详解(4)——入门程序nn本节演示使用SpringBoot整合RocketMQ的入门程序,包括消息的生产端和消费端两个工程。nn开发环境:JDK1.8、IntelliJ IDEA、Maven3.5.3、SpringBoot2.0.3、RocketMQ 4.3.0nn首先,引入RocketMQ的客户端依赖:nnnn&amp;lt;parent&amp;gt;n &amp;lt;groupId&amp;gt;o...
RocketMQ源码阅读附一TopicQueue的划分
n n n RocketMQ存储Topic消息时会按照TopicQueue进行划分. 如下图nnnnnnnnn首先按照BrokerName划分到不同的master上(每一个master可以有自己的slave,但是slave的BrokerName和master是一样的). 划分到具体的master后又回分到不同的queue上, 每一个master维护自己的queue(即...
RocketMQ 学习之四 —— RocketMQ Web管理界面
目录nn进入实战nn生产者代码:nn消费者代码:nn自动创建了 topicnn消费组:nn发送的消息:nn手动发信息:nn前一篇 讲了 Web 管理界面:https://blog.csdn.net/ruanhao1203/article/details/89451754#5%E3%80%81Rocket%20Web%E7%AE%A1%E7%90%86%E7%95%8C%E9%9D%A2nnnn...
4~RocketMQ-集群构建模型详解
RocketMQ是什么?topic主题(比拟公司)下的字标签 tags(比拟部门)创建topic默认会创建4个QueueProducer\Consumer\队列都可以分布式一个Consumer组也是可以同时监听两个队列RocketMQ网络部署特点1 Name Server是一个几乎无状态节点,单纯的做一个服务发现和路由的机制,可集群部署,节点之间无任何信息同步2 Broker部署相对复杂,Brok...
《RocketMq》六、Client-Consumer消费者详解
Consumer-集群Push模式-简介:0、背景介绍         Consumer主要用于向Broker请求Producer产生的消息,对其进行消费;对于RocketMQ,我们一定很好奇,如何实现分布式的Consumer消费,如何保证Consumer的顺序性,不重复性呢? 存在的问题:1. 如果在集群模式中新增/减少 组(group) 消费者,可能会导致重复消费;原因是:假设新增消费者前,C...
RocketMQ之路由管理
RocketMQ是一个分布式集群系统,每个节点之间都会进行通信,其中的通信逻辑使我们必须理清楚的。涉及到的组件包括:NameServer、Broker、Producer、Consumer,这里以Cluster结构为模型来分析各个节点之间的通信流程。路由管理是RocketMQ的核心功能之一,涵盖了订阅管理,连接管理,负载均衡等一系列功能,代码分布在NameServer、Broker、Producer...
RocketMQ在windows环境下部署介绍
文章目录RocketMQ在windows环境下部署介绍RocketMQ 官网下载二进制安装文件设置 MQ的环境变量启动 NameServer查看启动日志启动 BrokernRocketMQ在windows环境下部署介绍nnRocketMQ 官网下载二进制安装文件n首先在RocketMQ 官网下载二进制安装文件: http://rocketmq.apache.org/dowloading/rele...
RocketMQ异常(一)
RocketMQ异常(一)nnorg.apache.rocketmq.client.exception.MQClientException: No route info for this topic, TopicTestjjjnnn根据官方文档配置的MQ,并且复制的示例代码,但是运行就报错了。n参考了很多博客得出以下三种结论nnBroker没有开启自动创建主题nBroker 没有正确连接到 Nam...
文章热词 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型 设计制作学习
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 课程表数据库创建 数据库创建课程表

相似问题

1
rocketmq无法创建Topic
2
java创建的套接字可以被C语言使用吗?
3
用eclipse创建第一个JAVA项目怎么勾选JRE选项
1
Swing里为什么纵向的Box对象中嵌套一个横向的Box对象就会无法对齐?
3
微信公众号程序 在早晨8点 晚上5点左右 无法打开
6
Java 使用POI导出excel表格,无法将单元格设置为文本格式
4
Java指定路径文件的自动创建及写入
1
利用java将mysql数据库内容成为指定的格式并可以自动创建.txt文本
7
本机一个程序双击快捷方式可以打开,命令行却无法打开,试过几个其他程序都可以,不知道是怎么回事
6
js 用str+=拼接select标签 选中状态 替换jsp静态页面下拉菜单 无法展示选中状态
6
session无法在两个JSP页面中传值???????
4
Docker的mysql集群节点可以正常创建,但docker无法连接到宿主机的mysql应如何解决?
9
JSP里面,创建全局的Connection对象,为一个session会话服务,如何在session会话结束关闭数据库的连接?
9
POI 生成的word无法打开
9
如何理解 java编程思想中“静态方法可以创建其自身对象”这句话?
4
windows系统开发JAVAWEB的hadoop工程创建Configuration对象报错
3
java rocketmq 生产者如何取得消费者的消费结果
7
java Http请求发送成功,却无法获得返回值???
13
java SSM整合问题,无法进入Controller
3
idea中springboot项目,用springboot内置容器无法运行,但打包后手动部署可运行