问题一:在MQTT中,微消息队列topic有规划可以自定义吗?
问下微消息队列topic有规划可以自定义吗?
参考回答:
topic的设置支不支持+、#这种通配符
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/573127
问题二:在MQTT中,单个消息发送数据不能超过64k的有什么方案可以支持更大吗?
单个消息发送数据不能超过64k的有什么方案可以支持更大吗?我现在的应用场景是连接多,预计5万,但是tps 不高,不超过5,消息长度偶尔大于64k,不超过1%,可以定制吗,按照目前阿里云策略严重超标自建,有什么方案吗?
参考回答:
目前只有铂金版支持调整,上限1MB
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/573125
问题三:用RocketMQ 5.x的最新客户端 grpc + pop 是不是就可以实现消费组对应多个tp了?
用RocketMQ 5.x的最新客户端 grpc + pop 是不是就可以实现消费组对应多个tp了?
参考回答:
是的,RocketMQ 5.x的最新客户端通过使用 gRPC 协议以及 Pop 消费模式,可以让一个消费组对应多个 TopicPartition(TP)。这是一种新的消费模型,它可以提高消息消费的性能和灵活性。
在这种模型下,每个消费者实例可以订阅一个或多个 TopicPartition,而每个 TopicPartition 可以被多个消费者实例同时订阅。这样,一个消费组可以跨越多个 TP 进行消费,从而实现更高效的消息处理能力。
要使用这个新功能,您需要更新到 RocketMQ 5.x 或更高版本的客户端,并启用 gRPC 协议以及 Pop 消费模式。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571564
问题四:RocketMQ 是不是一个topic 只能对应一个消费组?用的是5.3版本。
RocketMQ client.exception.MQBrokerException: CODE: 24 DESC: the consumer's subscription not exist 问下是不是一个topic 只能对应一个消费组?我用的是5.3版本。如果不是,那这个报错是什么原因呢?目前程序设置的是 一个消费组对应多个topic
参考回答:
不是。看看topic和消费组是否对应上,而且rmq不建议一个消费组消费多个topic,这点还是和kafka有区别的。如果用的是remot的方式,那还是区分开,一个topic用一个group。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571563
问题五:rocketmq官方对于kafka作为数据源这种情况,比较推荐的使用方式是什么?
为什么rocketmq-connect-kafka的pom文件配置了packaging为pom,这样会使得打包的结果并不是plugins需要的jar包。如果是pom,是不是在其他地方把rocketmq-connect-kafka作为了父依赖,需要配合其他connect进行使用。我找了网上的实践方案,kafka作为数据源的案例检索到的结果好像比较少,我想知道官方对于kafka作为数据源这种情况,比较推荐的使用方式。
参考回答:
这个 kafka-connect, pom 需要修改一下, 构建出 含有 『org.apache.rocketmq.connect.kafka.connector.KafkaSourceConnector』 的 jar包,这样 才能正常运行。
或者看看是不是这个 kafkaSourceConnector 继承的 SourceConnector 的包的版本太低了,插件是根据 SourceConnector 来识别的,要是包不对,就加载不上,可能需要升级一下,可能需要重新实现 org.apache.rocketmq.connect.kafka.connector.KafkaSourceConnector 。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571552