在面对众多的消息队列时,我们往往会陷入选择的困境:“消息队列那么多,该怎么选啊?Kafka 和 RabbitMQ 比较好用,用哪个更好呢?”想必大家也曾有过类似的疑问。对此本文将在接下来的内容中以 Kafka 和 RabbitMQ 为例分... **业务需求:** 要明确你的业务需要什么样的消息队列功能。例如,是否需要支持延时消息、死信队列、事务消息等高级功能,还是只需要基本的生产和消费功能。5. **数据量:** 考虑你的数据量是否大,是否需要高吞吐率和...
作者|字节跳动消息队列研发工程师-雷丽媛上文我们了解了在字节跳动内部业务快速增长的推动下,经典消息队列 Kafka 的劣势开始逐渐暴露,在弹性、规模、成本及运维方面都无法满足业务需求。因此字节消息队列团队... 当一个消费请求到达 Kafka Broker,Broker 会查看当前是否有足够多的已写入数据返回给消费者,如果条件满足则会读取数据并返回。这个流程非常简单清晰,但这个流程不能直接照搬到 BMQ,因为 BMQ 底层是分布式存储系统,...
# 前言 [#](https://vsop-online.bytedance.net/doc/manage/detail/6627/detail/?DocumentID=173809#%E5%89%8D%E8%A8%80)Kafka MirrorMaker 是 Kafka 官网提供的跨数据中心流数据同步方案,其实现原理是通过从 Source 集群消费消息,然后将消息生产到 Target 集群从而完成数据迁移操作。用户只需要通过简单的consumer配置和producer配置,启动MirrorMaker,即可实现实时数据同步。![图片](https://portal.volccdn.com/obj/volcfe/c...
文 | **洪剑**、**大滨** 来自字节跳动数据平台开发套件团队# 背景## 动机字节数据中台DataLeap的Data Catalog系统基于Apache Atlas搭建,其中Atlas通过Kafka获取外部系统的元数据变更消息。在开源版本中,每台... 其实只是简单的读取和处理,使用Flink有些“杀鸡用牛刀”了。另一个比较标准的方案是Kafka Streaming。作为Kafka官方提供的框架,对于流式处理的语义有较好的支持,也满足我们对于轻量的诉求。最终没有采用的主要考...
消息队列 Kafka版提供以下实例管理相关的常见问题供您参考。 FAQ 列表如何选择计算规格和存储规格 如何选择云盘 如何删除或退订实例 是否支持压缩消息? 是否支持多可用区部署 Kafka 实例? 单 AZ 实例如何切换为多 ... Kafka 客户端代码配置简单便捷。通过 SASL_PLAINTEXT 接入点连接 Kafka 实例的操作步骤,请参考使用 SASL_PLAINTEXT 接入点连接实例。 支持哪些语言的客户端?火山引擎消息队列 Kafka版支持开源 Apache Kafka 提供的...
应用接入消息队列 Kafka版之前,需要在控制台创建 Kafka 实例。消息队列 Kafka版提供多种实例规格,对应不同的计算能力和存储空间,您可以根据实际业务需求选择不同的实例规格。本文介绍创建 Kafka 实例的操作步骤。 ... 实例描述 Kafka 实例的简单描述。长度范围为 1~128 个字符。 填写 Kafka 实例的规格配置。 参数 说明 部署方案 实例在当前地域的部署方式。支持设置为: 单可用区部署:在当前地域下的指定可用区创建 Kafka...
背景信息Kafka 作为高吞吐量的消息中间件,在多种自建场景的日志采集方案中被用于消息管道。例如在日志源服务器中的开源采集工具采集日志,或通过 Producer 直接写入日志数据,再通过消费管道供下游应用进行消费。日志服务支持通过 Kafka 协议上传和消费日志数据,基于 Kafka 数据管道提供完整的数据上下行服务。使用 Kafka 协议上传日志功能,无需手动开启功能,无需在数据源侧安装数据采集工具,基于简单的配置即可实现 Kafka Produc...
是否开启分区的自动分裂功能。 (默认)开启:当写入的数据量连续 5 分钟超过已有分区服务能力时,日志服务会根据数据量自动分裂分区以满足业务需求,但分裂后的分区数量不可超出最大分裂数。最近 15 分钟内分裂出来的新分区不会自动分裂。 关闭:不开启分区的自动分裂。 最大分裂数 分区的最大分裂数,即分区分裂后,所有分区的最大数量。取值范围为 1~10,默认为 10。 描述 日志主题的简单描述。 开通 Kafka 协议消费。在项目详情...
是否开启分区的自动分裂功能。 (默认)开启:当写入的数据量连续 5 分钟超过已有分区服务能力时,日志服务会根据数据量自动分裂分区以满足业务需求,但分裂后的分区数量不可超出最大分裂数。最近 15 分钟内分裂出来的新分区不会自动分裂。 关闭:不开启分区的自动分裂。 最大分裂数 分区的最大分裂数,即分区分裂后,所有分区的最大数量。取值范围为 1~10,默认为 10。 描述 日志主题的简单描述。 开通 Kafka 协议消费。 在项目详...
在面对众多的消息队列时,我们往往会陷入选择的困境:“消息队列那么多,该怎么选啊?Kafka 和 RabbitMQ 比较好用,用哪个更好呢?”想必大家也曾有过类似的疑问。对此本文将在接下来的内容中以 Kafka 和 RabbitMQ 为例分... **业务需求:** 要明确你的业务需要什么样的消息队列功能。例如,是否需要支持延时消息、死信队列、事务消息等高级功能,还是只需要基本的生产和消费功能。5. **数据量:** 考虑你的数据量是否大,是否需要高吞吐率和...
调用CreateInstance创建消息队列 Kafka版实例。 使用说明实例是消息队列 Kafka版服务的虚拟机资源,用于管理和存储 Topic、Group 等资源。 注意事项如果是首次创建 Kafka 实例,您需要先完成跨服务访问授权,建议通过... InstanceDescription String 否 instance for test Kafka 实例的简单描述。长度范围为 1~128 个字符。 Parameters String 否 "{"MessageMaxByte": "10","LogRetentionHours": "72","OffsetRetentionMin...
消息队列 Kafka版支持通过控制台创建 Group,或通过消费 SDK 解析获取并展示 Group 的信息。关闭自由使用 Group 功能后,只能通过控制台创建 Group。本文档展示创建 Group 的方式及操作步骤。 背景信息消费组(Consum... 描述 Group 的简单描述。创建 Group 后可以在 Group 管理页面中查看或修改描述。 标签 单击添加标签,输入标签键和标签值,为 Group 添加自定义标签。标签用于云资源的标识与分类,添加标签有利于识别和管理 Gro...
消息队列 Kafka版实例提供专有网络 VPC 和公网访问方式,不同的网络环境对应不同的接入点。接入消息队列 Kafka版收发消息时,需要根据网络环境和认证机制选择对应的接入点。本文档介绍不同接入点的区别及查看接入点的... 在消息队列 Kafka版中,公网环境和 VPC 环境均提供 SASL 接入点供您选择。Kafka 实例支持以下两种 SASL 机制,您可以根据业务需求选择不同的身份认证方式。 PLAIN 机制:一种简单的用户名密码认证方式,安全性较低。密...