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
updateTopic命令很多人都知道,也在博客上复制粘贴了官网的。但很多人没有给出具体的简单例子,对于初学者而言要的就是直观的例子,可以拷贝下来改个数字直接使用的例子。文档大家都知道看,但很多人看了还是不知道具体怎么去做。因为官网只是给一个介绍。具体命令怎么使用需要靠自己摸索。 updateTopic命令主要是三个参数: -b broker_id:broker_port  ,ip都知道就...
分布式消息队列RocketMQ源码分析之1 -- Topic路由数据结构解析 -- topicRoute与topicPublishInfo与queueId
在前1篇RokcetMQ与Kafka架构差异一文中,我们已经讨论了2者在Topic的路由结构,也即topic/partition与物理机器的映射关系上的巨大差异。这个差异也是2者在架构上的一个巨大差异点,也是导致RocketMQ可以去除ZK依赖的一个重要原因。 本篇将接着这个话题,进一步从源码角度深度解析Topic的路由数据结构。至所以把“topic路由结构“作为源码分析的首篇,是因为这个话题串...
1.偏头痛杨的rocketmq4.x入门之基础概念扫盲篇
前戏 阅读本文之前,读者必须自己清楚什么是消息队列,以及消息队列的一些基本概念,例如:消息、生产者、消费者等。 我们如果需要玩异步、分布式事务、代码物理解耦、削峰平谷、发布订阅等等,可以使用消息队列中间件, 那么阿里的rocketmq是一款比较中意的产品,既有开源版又有商业版(阿里云的mq有点贵,谁用谁知道)。 商业版与开源版的api不同,有的概念也不同。。。 rocketmq的
RocketMQ管理命令说明
1.1.  控制台使用 RocketMQ提供有控制台及一系列控制台命令,用于管理员对主题,集群,broker等信息的管理; l  登录控制台: 首先进入RocketMQ工程,进入/RocketMQ/bin 在该目录下有个mqadmin脚本 l  查看帮助: 在mqadmin下可以查看有哪些命令               shmqadmin l  查看具体命令的使用 sh mqa
RocketMQ常用命令使用示例及说明
1. 前言 本文主要为RocketMQ的大部分客户端运维命令的基本使用示例,文中使用的参数为最少必须参数,相关参数会有简单介绍。 本文说明的命令基于RocketMQ的3.5.8版本,有些命令可能在更低版本中并不存在。 运维命令脚本放在bin目录下。 本文使用的测试集群为2m-noslave集群。 笔者会尽量把大部分的命令举例说明,但是每个命令的具体参数说明,请通过--help查看或者查阅...
RocketMQ入门(2.快速入门)
本文档主要包含以下内容: 如何开通 MQ 服务如何申请 MQ 资源如何通过 MQ 进行消息收发 MQ 快速接入流程图: 1.开通MQ服务 在阿里云官方网站开通MQ服务。 2.申请MQ资源 在 MQ 消息系统中,消息发布者将消息发送到某个指定的消息主题(Topic) ,而消息订阅者则通过订阅该指定的 Topic 来获取和消费消息。因此一个新的应用接入
Kafka vs RocketMQ——多Topic对性能稳定性的影响
引言上期我们对比了RocketMQ和Kafka在多Topic场景下,收发消息的对比测试,RocketMQ表现稳定,而Kafka的TPS在64个Topic时可以保持13万,到了128个Topic就跌至0.85万,导致无法完成测试。我们不禁要问:为什么看不到Kafka性能暴跌的趋势呢?今天的测试,就来排查一下这个问题,然后验证一下两个系统对外服务的稳定性。本次测试,要引入“稳定性测试”这个概念,那什么...
从 Apache RocketMQ 和 Kafka 看 Topic 数量对单机性能的影响
摘要: 这次,我们来模拟一个真实的场景: * 消息的发送和订阅一定是共存的 * 要支持多个订阅端订阅自己感兴趣的消息 我们将针对 RocketMQ 和 Kafka,对比在上述场景中,究竟谁更胜一筹。 阿里云消息队列测试小组 出品 上一期我们对比了三类消息产品(Kafka、RabbitMQ、RocketMQ)单纯发送小消息的性能,受到了程序猿们的广泛关注,其中大家对这种单纯的发送场景感到
RocketMQ——Producer篇:其他功能介绍
1 向Broker发送心跳消息1、初始化HeartbeatData对象,将该Producer或Consumer的ClientID赋值给HeartbeatData对象的clientID变量;2、遍历MQClientInstance.consumerTable: ConcurrentHashMap<String/* group */, MQConsumerInner>变量,根据每个MQConsumer
RocketMQ概念模型
RocketMQ概念模型 一 前言   对于任何一款中间件产品而言,清晰的概念模型是帮助用户正确理解使用它的关键。由于RocketMQ并没有遵循业界现有的JMS或AMQP规范,而且功能集比后两者更加丰富,描述该中间件产品的概念模型是一项比较有挑战的任务。RocketMQ的官方文档《RocketMQ 原理简介》对产品的概念模型给出了比较简洁而清晰的介绍。   本文将针对用户在使用RocketM
RocketMQ常用命令
转自: 1.1. 控制台使用 RocketMQ 提供有控制台及一系列控制台命令,用于管理员对主题,集群,broker 等信息的管理; 登录控制台 首先进入RocketMQ 工程,进入/RocketMQ/bin 在该目录下有个mqadmin 脚本 查看帮助 在mqadmin 下可以查看有哪些命令 sh mqadmin 查看具体命令的使用 s
rocketmq问题汇总-一个consumerGroup只对应一个topic
1 同一个订阅组内不同Consumer实例订阅不同topic消费混乱问题调查 图1: 背景说明: 如图1左半部分,假设目前的关系如下: broker: 两个,broker_a和broker_b topic:两个,topic1和topic2,每个topic在每个broker上分为4个queue consumer:两个,consumer1和consumer2
RocketMQ中的message queue是个什么,该怎么理解?
RocketMQ中的message queue是个什么,该怎么理解? 1. 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
RocketMQ4.3.0集群搭建和部署rocketMq监控平台
集群部署(采用2个master,2个slave异步复制的集群结构)   RocketMQ具有以下特点: 1)是一个队列模型的消息中间件,具有高性能、高可靠、高实时、分布式特点。 2)Producer、Consumer、队列都可以分布式。 3)Producer向一些队列轮流发送消息,队列集合称为Topic,Consumer如果做广播消费,则一个consumer实例消费这个Topic对应...
【rocketmq】找不到topic,route info 异常问题原因及解决方案
参考 RocketMQ的autoCreateTopicEnable配置 RocketMQ 解决 No route info of this topic 异常步骤 标题 版权声明: https://blog.csdn.net/ph3636/article/details/79528638 1.使用RocketMQ进行发消息时,必须要指定topic,对于topic的设置有一个开关aut...
RocketMq学习使用总结
1、mqnamesrv单机启动2台服务,可以通过-c xxx.properties指定端口号(如:listenPort=9877,默认端口号9876)   2、master、slave异步复制模式 master宕机,slave不能自动切换到master。单个master/slave模式,生产消息受影响; slave宕机,完全没影响。   3、producer生产消息轮询队列策略 默...
使用RocketMQ的小细节
消息过滤 说到消息过滤,就不得不说到 tag。没错,就是我们之前在专业术语中提到过的 tag。也称为消息标签,用来标记 Topic 下的不同用途的消息。 在 RocketMQ 中消费者是可以按照 Tag 对消息进行过滤。举个电商交易场景的例子,用户下完订单之后,在后台会产生一系列的消息,比如说订单消息、支付消息和物流消息。假设这些消息都发送到 Topic 为 Trade 中,同时用 tag...
在Windows上搭建RocketMQ的流程和注意事项
由于需要在本地开发RocketMQ,于是在windows环境下搭建了一套RocketMQ的环境,记下来搭建的流程和注意的问题。 一,在github上下载RocketMQ的项目 github的地址是:https://github.com/alibaba/RocketMQ/releases 我选择的是3.2.6的版本,页面上是这样的: 在Downloads那一栏有下载项,其中Sourc
《RocketMq》七、Broker中心节点
broker的位置和结构图:由于之前已经把存储,网络分解出来进行了详细的分析,因此Broker部分变得较简单,这里主要分为以下几个部分来说:一、Broker与NameSrv交互Broker会不断发送register信息给NameSrv,将自身的clusterName,brokerName,topic信息发送到Namesrv;而Consumer和Producer则会通过Namesrv获取信息,这里最...
RocketMQ——Producer篇:发送普通消息
以DefaultMQProducer.send(Message msg)方法为例,讲解Producer消息的发送逻辑,该方法最终调用DefaultMQProducerImpl.sendDefaultImpl(Message msg, CommunicationMode communicationMode, SendCallback sendCallback, long timeout)方法完成消息的
RocketMQ在windows上安装和开发使用
1.概述 RocketMQ是alibaba公司开源的一个纯java的开源消息中间件。 2.开发测试环境搭建 1.   安装&启动 进入到RocketMQ下载包解压的路径下 D:\machine\RocketMQ-3.0.8\RocketMQ-3.0.8> 接下来安装 执行下边的命令或者执行install.bat(在这个bat文件中的命令如下)对maven熟悉的一眼就知
RocketMQ nameserver、broker、生产者和消费者之间的关系
一 nameserver 相对来说,nameserver的稳定性非常高。原因有二: 1 nameserver互相独立,彼此没有通信关系,单台nameserver挂掉,不影响其他nameserver,即使全部挂掉,也不影响业务系统使用,这点类似于dubbo的zookeeper。 2 nameserver不会有频繁的读写,所以性能开销非常小,稳定性很高。二 broker 1 与nameserve
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使用之发送消息分析(四)
前言 这篇文章还有一个疑问没解决,查了很多资料,源码也翻了好几遍还是没找出 Topic路由信息如果本地没获取到从NameSer获取缓存 为什么NameSer会有,它的路由信息是从哪里来的?为什么NameSer一定能获取到,因为所有的相关博客中都没考虑获取不到的情况。有点点猜想。我们在初始化Producer时和NameSer建立长连接,这其中在发送消息时是不是发生了什么事? 所以这里...
查看当前服务器中的所有的topic,创建topic,删除topic,通过shell命令发送消息,通过shell消费消息,查看topic详情,对分区数进行修改
一、 Kafka常用操作命令 查看当前服务器中的所有topic[root@hadoop3 kafka]# bin/kafka-topics.sh --list --zookeeper hadoop11:2181 [root@hadoop3 kafka]#信息写入到  创建topic[root@hadoop3 kafka]# bin/kafka-topics.sh --create --zook
RecketMQ-同一个订阅组下有多个Topic,消息能发送到Topic中,但无法被监听到
问题描述:现有多个应用,发送和监听消息使用的GROUP为同一个,在该GROUP下面有多个TOPIC,往其中一个TOPIC发送消息,消息能发送成功,但该TOPIC的监听类无法监听到该消息。 问题解决:修改监听类的GROUP属性,保证GROUP和TOPIC一一对应即可。 问题原因如下(转载https://blog.csdn.net/a417930422/article/details/506636...
queue与topic的区别
JMS中定义了两种消息模型:点对点(point to point, queue)和发布/订阅(publish/subscribe,topic)。主要区别就是是否能重复消费。点对点:Queue,不可重复消费消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且消费消息。 消息被消费以后,queue中不再有存储,所以消息消费者不可能消费到已经被消费的消息。Queue支持存在多个消费...
rocketmq查看命令
首先进入 RocketMQ 工程,进入/RocketMQ/bin   在该目录下有个 mqadmin 脚本 . 查看帮助:   在 mqadmin 下可以查看有哪些命令   a: 查看具体命令的使用 : sh mqadmin     b: sh mqadmin help 命令名称  例如,查看 updateTopic 的使用sh mqadmin help updateTopic2. 关闭names...
rocketMq - tag不一致造成的假象
概述     这篇文章是以同事在实际工作中遇到的问题作为分析的切入点,加深自己对mq的掌握,践行“干中学”的团队理念。     当自己差不多把基本概念都掌握的差不多的时候,必须需要实际的案例或者实践来提深自己的深度,这个时候just do it 变得很重要,所以我喜欢不停的被人挑战,截止目前帮人解答的问题包括:client端消息堆积问题、批量消息拉取问题中遇到的神奇的数字32、以及本篇的tag...
4~RocketMQ-集群构建模型详解
RocketMQ是什么?topic主题(比拟公司)下的字标签 tags(比拟部门)创建topic默认会创建4个QueueProducer\Consumer\队列都可以分布式一个Consumer组也是可以同时监听两个队列RocketMQ网络部署特点1 Name Server是一个几乎无状态节点,单纯的做一个服务发现和路由的机制,可集群部署,节点之间无任何信息同步2 Broker部署相对复杂,Brok...
Kafka vs RocketMQ—— Topic数量对单机性能的影响-转自阿里中间件
原文地址:http://www.cnblogs.com/felixzh/p/6198174.html 引言 上一期我们对比了三类消息产品(Kafka、RabbitMQ、RocketMQ)单纯发送小消息的性能,受到了程序猿们的广泛关注,其中大家对这种单纯的发送场景感到并不过瘾,因为没有任何一个网站的业务只有发送消息。本期,我们就来模拟一个真实的场景: 消息的发送和订阅一定是共存的要支持多个
RocketMQ搭建问题,brokerIP修改不生效
问题: 搭建设备中有多个网卡,broker在启动时默认选择了一个网卡,由于网段不对,不能在外部访问,而在broker配置文件中修改brokerIP1=10.1.1.1并不生效。 原因: 当使用命令 sh mqbroker -m &amp;gt;../conf/me-2m-2s-async/broker.p 创建配置文件broker.p时,默认生成的文件带了时间等格式,如下图: 当我使用网上的例...
rocketmq问题汇总-一个consumerGroup只对应一个topic
1 同一个订阅组内不同Consumer实例订阅不同topic消费混乱问题调查 图1: 背景说明: 如图1左半部分,假设目前的关系如下: broker: 两个,broker_a和broker_b topic:两个,topic1和topic2,每个topic在每个broker上分为4个queue consumer:两个,consumer1和consumer2,都属于group1...
RocketMQ 的基础与规范
在公司里边,负责消息中间件这块工作,也进行了内部知识的交流。但效果不太明显呀!今天把一些 Rocketmq 的重要的知识点整理出来! Producer 消息生产者,负责产生消息,一般由业务系统负责产生消息。 Consumer 消息消费者,负责消费消息,一般是后台系统负责异步消费。拉取后的消息,是放在线程池里面的。 Pull Consumer Consumer 的一种,应用通常竹筒调用
RocketMQ 一些核心概念
Producer:生产者,一个生产者发送业务应用系统生成的数据给Brokers(经纪人)。RocketMQ提供多范式发送:同步,异步,一站式。 Producer Group:生产者组,是将同样角色生产者的分组在一起。同一生产组的不同生产者实例都会被Broker经纪人联络告知提交或者回滚事务,以避免事务后源生产者崩溃。 注:考虑到提供的生产者在发送消息时足够给力时,一个生产者组仅允许一个生产者实例,
RocketMQ 常用管理命令
1.1.  控制台使用RocketMQ提供有控制台及一系列控制台命令,用于管理员对主题,集群,broker等信息的管理;l  登录控制台:首先进入RocketMQ工程,进入/RocketMQ/bin在该目录下有个mqadmin脚本l  查看帮助:在mqadmin下可以查看有哪些命令              shmqadminl  查看具体命令的使用sh mqadmin help 命令名称例如,查...
RocketMQ源码分析----发送消息
主要步骤 发送消息的主要流程总结如下步骤: 1.获取Topic信息TopicPublishInfo:tryToFindTopicPublishInfo a) 从缓存map topicPublishInfoTable中获取 b) 空则新建 c) 更新topic信息:updateTopicRouteInfoFromNameServer
《RocketMq》六、Client-Consumer消费者详解
Consumer-集群Push模式-简介:0、背景介绍         Consumer主要用于向Broker请求Producer产生的消息,对其进行消费;对于RocketMQ,我们一定很好奇,如何实现分布式的Consumer消费,如何保证Consumer的顺序性,不重复性呢? 存在的问题:1. 如果在集群模式中新增/减少 组(group) 消费者,可能会导致重复消费;原因是:假设新增消费者前,C...
分布式消息队列RocketMQ与Kafka架构上的巨大差异之2 -- CommitLog与ConsumeQueue
在前面Rocket与Kafka的对比之“拨乱反正”续篇中,我们已经提到了RocketMQ和Kafka在架构上面的一个巨大差异:Kafka是每个partition对应一个文件,而RocketMQ是把所有topic的所有queue的消息存储在一个文件里面,然后再分发给ConsumeQueue。 有兴趣朋友可以关注公众号“架构之道与术”, 获取最新文章。 或扫描如下二维码: 存储上的巨大差异 ...
RocketMQ路由错误
如果报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...
文章热词 Solidity存储器阵列创建 h.264码流工程创建 数组创建bytes字节 字节数组类型创建 联盟链POA创建方法
相关热词 vs无法创建c# c# 无法打开设计 c++release情况无法运行 python教程+chm python教程百家号

相似问题

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会话结束关闭数据库的连接?
8
POI 生成的word无法打开
9
如何理解 java编程思想中“静态方法可以创建其自身对象”这句话?
4
windows系统开发JAVAWEB的hadoop工程创建Configuration对象报错
3
java rocketmq 生产者如何取得消费者的消费结果
7
java Http请求发送成功,却无法获得返回值???
13
java SSM整合问题,无法进入Controller
3
idea中springboot项目,用springboot内置容器无法运行,但打包后手动部署可运行