消息中间件

关于Flink弹性扩缩容有个疑问：比如Kafka12个分区，Flink任务（KafkaSource -> Process -> BDSink）On Yarn appli…

机器学习PAI这个问题怎么解决？利用官方的webui教程，容器搭建了一套，在webui上配置了一个csv到kafka的流程，一直报kafka的factory找不到。 以下为热心网友…

在RabbitMQ&AMQP使用rabbitmq的延时消息，有没有不使用sdk代码添加header的。可以直接在spring的amqp添加header吗？

阿里云Serverless中我们使用 mns消息队列触发函数计算function，发现消费成功之后还是会一直消费到，这个要怎么处理？我们请求成功了，但是不知道。要返回啥出去才算消费…

在阿里函数计算函数通过事件总线接收RocketMQ的消息时，有时候某些MQ的消息并不会触发函数，这种问题一般可能时什么原因引起的？

dataworks可以直接消费rocketmq的消息吗？ 以下为热心网友提供的参考意见 目前还未支持该类型数据源 https://help.aliyun.com/zh/datawo…

flink 消费kafka,之前任务正常的，突然有个分区没法消费了，重启下任务久正常了？

RocketMQ直cpu高水位有大神可以帮忙看下吗？

RocketMQ 5.1.4集群部署在内网环境，分散在3台内网机器上（都没有公网ip），然后把内网集群的nameserver的端口9876映射到公网，外部公网环境的java服务可以…

RocketMQ消息消费失败，进入死信队列，怎么重新消费，需要有一个专门的consumer监听死信队列吗？ 以下为热心网友提供的参考意见 当RocketMQ消息消费失败，消息会进入…

咨询个RocketMQ版本维护的问题，目前生产使用的是4.x的最新版4.9.7，想问下4.x版本的更新维护截止日期是什么时候？现在是否有必要一定升级到5.x版本？能提供下原始的网址…

RocketMQ我这边是3个RocketMQ的集群，主从，用了controller和proxy。生产者、消费者客户端也有3个。这样是能正常生产消费的。问题是：现在是消息一直在其中一…