[帮助文档] 开启幂等功能时, 发送报“Cluster authorization failed”错误

问题描述开启幂等功能后,发送消息时客户端报Cluster authorization failed错误。Cluster authorization failed问题原因您使用了云存储Topic,云存储Topic不支持幂等功能。如果使用Local Topic,并开启了ACL功能,默认情况下,根据Kaf...

[帮助文档] 单可用区升级为多可用区部署

当您使用的是专业版实例,且部署时仅选择了单可用区部署,可以通过编辑备可用区,升级集群为多可用区架构部署,从而增强集群的容灾能力。

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

[帮助文档] 使用ACL功能进行访问控制

当需要对不同的用户或用户组授予不同级别的访问权限时,您可以使用云消息队列 Kafka 版专业版实例的访问控制列表(ACL)功能,为SASL用户赋予对Topic、Group等资源的操作权限,实现细粒度的权限管理。

[帮助文档] 云消息队列 Kafka 版如何使用自定义权限策略

如果系统权限策略不能满足您的要求,您可以创建自定义权限策略实现最小授权。使用自定义权限策略有助于实现权限的精细化管控,是提升资源访问安全的有效手段。本文介绍云消息队列 Kafka 版使用自定义权限策略的场景和策略示例。

[帮助文档] 支持的预设的系统权限策略列表

本文描述消息队列Kafka版支持的所有系统权限策略及其对应的权限描述,供您授权 RAM 身份时参考。

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(下)

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(下)

就是来了波狸猫换太子,其实延时消息也是这么实现的,最终将换了皮的消息入盘。Broker 处理提交或者回滚消息的处理方法是 EndTransactionProcessor#processRequest,我们来看一看它做了什么操作。可以看到,如果是提交事务就是把皮再换回来写入真正的topic所属的队列中...

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(上)

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(上)

每个时代,都不会亏待会学习的人。大家好,我是 yes。今天我们来谈一谈消息队列的事务消息,一说起事务相信大家都不陌生,脑海里蹦出来的就是 ACID。通常我们理解的事务就是为了一些更新操作要么都成功,要么都失败,不会有中间状态的产生,而 ACID 是一个严格的事务实现的定义,不过在单体系...

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(下)

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(下)

Kafka 中的长轮询像 Kafka 在拉请求中有参数,可以使得消费者请求在 “长轮询” 中阻塞等待。简单的说就是消费者去 Broker 拉消息,定义了一个超时时间,也就是说消费者去请求消息,如果有的话马上返回消息,如果没有的话消费者等着直到超时,然后再次发起拉消息请求。并且 Broker 也得配合...

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(上)

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(上)

每个时代,都不会亏待会学习的人大家好,我是 yes。今天我们就来谈一谈消息队列的推拉模式,这也是一个面试热点,例如你在简历里面写了 RocketMQ ,基本上会问你 RocketMQ 采用的是推模式还是拉模式啊?是拉模式?不是有 PushConsumer 吗?今天我们就来谈谈推拉模式&...

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