Avatar notebook default
rocketMq
13篇文章 · 9316字 · 8人关注
  • rocketmq定时清理commitlog文件源码分析

    rocketmq的配置参数 猜想rocketmq会起一个一天执行一次的定时任务。但看了代码发现并不是这样。 在存储服务启动时，启动如下的定时任务...

    5915 0 2
  • Resize,w 360,h 240
    rocketmq console控制台Q&A

    q：为什么主备昨天的统计数据不一致？ A：获取昨天的统计数据是一个定时任务。每天零点执行。两台机器的执行不可能极其一致，总会差一点。 org/a...

    5428 0 0
  • Resize,w 360,h 240
    继续说死信队列

    继续说这个死信队列。 如果你去查询这个%DLQ%TestConsumer1死信队列，会发现查询不到。 但是到broker上看，这个Queue是有...

    788 0 0
  • Resize,w 360,h 240
    rocketmq的重试队列和死信队列

    消费端，一直不回传 消费的结果。rocketmq认为消息没收到，consumer下一次拉取，broker依然会发送该消息。 所以，任何异常都要捕...

    0.2 19133 1 4
  • rocketmq4.1.0部署详细步骤

    编译按照官方说明：http://rocketmq.apache.org/docs/quick-start/ git clone -b devel...

    0.2 1616 0 2
  • 他处找到的对参数讲的最全的

    1，createBrokerControllerSystem.setProperty(RemotingCommand.RemotingVersi...

    1092 0 0
  • RocketMq设置CONSUME_FROM_LAST_OFFSET的问题

    consumer在消费时，会设置从哪里开始消费。默认是CONSUME_FROM_LAST_OFFSET设置的值如代码所示。 这里要注意代码注释。...

    0.2 15871 2 2
  • RocketMq知识点理解

    RocketMq关键点理解 各个角色间的关系： RocketMq中每个Broker（master和slave）与Name Server集群中的所...

    0.1 2698 0 7
  • Resize,w 360,h 240
    RocketMq消息存储

    一个消息中间件最核心的东西就是消息存储结构。 这是kafka的消息存储： 每个topic_partition对应一个日志文件，Producer对...

    0.3 5661 0 5

文集作者