zoukankan      html  css  js  c++  java
  • 转战 rocketmq

    接触 kafka 有一段时间了,一个人的力量实在有限,国内 rocketmq 的生态确实更好,决定换方向。

    rocketmq 文档地址:http://rocketmq.cloud/zh-cn/docs/bestpractice-broker.html

    windows 环境下测试,

    启动 nameserver:

    mqnamesrv.cmd -n localhost:9876

    启动 broker:

    mqbroker.cmd -n localhost:9876

    创建 topic,创建的 topic 默认 8 个分区:

    mqadmin.cmd updateTopic -n localhost:9876 -b localhost:10911 -t TopicTest

    查看 topic 分区信息:

    mqadmin.cmd topicStatus -n localhost:9876 -t TopicTest

    根据分区 offset 查询消息:

    mqadmin.cmd queryMsgByOffset -n localhost:9876 -b zhang -i 0 -o 30 -t TopicTest

    windows 单机部署 2m

    ----------- broker-a.propertes
    listenPort=10911
    namesrvAddr=localhost:9876
    storePathRootDir=D:\tools\rocketmq-all-4.3.2-bin-release\store
    storePathCommitLog=D:\tools\rocketmq-all-4.3.2-bin-release\store\commitlog
    
    
    ----------- broker-b.propertes
    listenPort=20911
    namesrvAddr=localhost:9876
    storePathRootDir=D:\tools\rocketmq-all-4.3.2-bin-release\store2
    storePathCommitLog=D:\tools\rocketmq-all-4.3.2-bin-release\store2\commitlog

    启动

    mqbroker.cmd -c ../conf/2m-noslave/broker-a.properties
    mqbroker.cmd -c ../conf/2m-noslave/broker-b.properties

     集群环境下,创建 topic:

    mqadmin.cmd updateTopic -n localhost:9876 -c DefaultCluster -t topic-zhang

    这样会在 2 个 master 上分别创建 8 个分区。代码逻辑在 org.apache.rocketmq.tools.command.topic.UpdateTopicSubCommand#execute 中。

  • 相关阅读:
    免费的mysql客户端管理工具
    vue配置反向代理
    composer下载地址
    mysql多个字段模糊查询是否包含某个词
    Laravel 7 中文文档
    datatable显示文字改为中文
    MongoDB
    node 与 Ajax 的等待响应
    关于 <!DOCTYPE html> 对移动端和PC端的影响
    Vue中 scoped属性
  • 原文地址:https://www.cnblogs.com/allenwas3/p/11376010.html
Copyright © 2011-2022 走看看