问答 2024-08-20 来自:开发者社区

在使用rocketMQ中创建producer时报出如下错误,该如何解决?

在使用rocketMQ中创建producer时报出如下错误:Error starting gRPC call. HttpRequestException: Requesting HTTP version 2.0 with version policy RequestVersionOrHigher while unable to establish HTTP/2 connection.该如何解决

问答 2024-07-10 来自:开发者社区

RocketMQ本地启动了producer服务,也能正常发送消息,但是搜不到是什么原因呢?

RocketMQ本地启动了producer服务,也能正常发送消息,但是dashbroad上这里搜不到是什么原因呢?

文章 2024-06-30 来自:开发者社区

消息队列 MQ产品使用合集之broker开启proxy,启动之后producer生产消息始终都只到一个broker,该怎么办

问题一:RocketMQ中broker开启proxy,启动之后,是需要什么配置 ? RocketMQ中broker开启proxy,启动之后,producer生产消息始终都只到一个broker,是需要什么配置 ? 参考答案: grpc 的producer需要配置全部的proxy地址, broker不用管。 关于本问题的更多回答...

消息队列 MQ产品使用合集之broker开启proxy,启动之后producer生产消息始终都只到一个broker,该怎么办
文章 2023-12-27 来自:开发者社区

RocketMQ源码(三)简单探索Producer和Consumer与Queue之间的负载均衡策略

RocketMQ源码(三)简单探索Producer和Consumer与Queue之间的负载均衡策略 在RocketMQ架构中,我们都知道一个topic下可以创建多个queue,生产者通过负载均衡策略可以将消息均匀的分发在各个queue中,而这些queue可以通过负载均衡给多个消费者订阅从而提升消费效率,本文将从以下两个方面从源码角度分析producer和consumer的负载均衡原理: ...

RocketMQ源码(三)简单探索Producer和Consumer与Queue之间的负载均衡策略
阿里云文档 2023-09-13

RocketMQ生产者的定义、模型关系、内部属性、版本兼容性及使用建议_云消息队列 RocketMQ 5.x系列_云消息队列 RocketMQ 版(RocketMQ)

本文介绍云消息队列 RocketMQ 版中生产者(Producer)的定义、模型关系、内部属性、版本兼容性及使用建议。

文章 2023-08-20 来自:开发者社区

关于RocketMQ Producer某个性能优化点的分析

背景介绍在上一篇文章【一次RocketMQ ons Bug导致消息不断堆积到重试队列的案例分析】,我们有提到为了优化Producer性能问题对Pandora进行了升级,升级后出现了问题。下面我们对Producer的这个优化点进行下分析记录。问题描述SLB(LVS+TEngine)在云平台的重要性不言而喻,随着应用规模不断增大,LVS节点单核CPU使用率有达到70%的情况,经过排查发现LVS集群C....

关于RocketMQ Producer某个性能优化点的分析
问答 2023-08-05 来自:开发者社区

RocketMQ中producer发一次批量消息能做到一个batch分散到一个topic中多个队列么

想问一下在RocketMQ中producer发送一次批量消息的话能做到一个batch分散到一个topic中的多个队列吗?我看send方法好像每次是选定一个messagequeue的。

问答 2023-04-27 来自:开发者社区

RocketMQ Producer secretKey解析错误

com.alibaba.otter.canal.connector.core.producer.AbstractMQProducer 版本 1.1.5 alpha 123行 mqProperties.setAliyunAccessKey(aliyunSecretKey); 原提问者GitHub用户gangxing

文章 2023-02-20 来自:开发者社区

关于 RocketMQ:The producer group has been created before, specify another name please. 这个报错的解决办法

1. 在网上看了一些解决这个问题的办法,大部分朋友都说是要在实例化 DefaultMQProducer 的时候指定惟一的 instanceName 来解决,窃以为这样虽然解决了问题,但却是不应该用的解决办法。为什么这样说?因为官网介绍客户端公共参数的时候对这个 instanceName 有明确的说明instanceNameDEFAULT客户端实例名称,客户端创建的多个 Producer、Cons....

问答 2022-06-15 来自:开发者社区

请教一下,rocketmq producer发送事务消息时,执行本地事务,client把异常吞了这个

请教一下,rocketmq producer发送事务消息时,执行本地事务,client把异常吞了这个,怎么解决?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。