消息队列 Kafka版提供以下实例管理相关的常见问题供您参考。

FAQ 列表

• 如何选择计算规格和存储规格
• 如何选择云盘
• 如何删除或退订实例
• 是否支持压缩消息？
• 是否支持多可用区部署 Kafka 实例？
• 单 AZ 实例如何切换为多 AZ？
• 变更实例规格或扩容实例会影响业务吗？
• 如何为实例增加分区？
• 是否可以删除分区？
• 为什么不能减少分区？
• 是否支持缩容？
• 公网环境必须使用 SASL_SSL 吗？
• 支持哪些语言的客户端？
• 支持的消息体最大是多少？
• 消息的保留时间是多久？
• 支持的 Kafka 版本包括哪些？

如何选择计算规格和存储规格？

消息队列 Kafka版提供多种实例规格供您选择，你可以根据业务的读写流量峰值、所需的存储空间大小和分区数量估算计算规格与存储规格。

• 读写流量：
  • 购买时选择网卡读流量峰值和网卡写流量峰值中的较大值进行评估。
  • 建议按实际流量增加 30% 进行评估，再根据其它参数选择适合的实例规格。
• 存储空间大小：实际占用的存储空间=业务消息体积 × 副本数 ÷ 75%
  • 支持多副本存储，存储空间包含所有副本存储空间总和。
  • 因部分存储将用于日志和元数据数据存储，冗余消息也可能带来额外的空间占用，实际可用存储会小于设置的存储规格，建议预留 25% 左右的存储空间。
• 分区数量：根据实际的业务需求设置分区数量。每个计算规格提供一定的免费分区额度，您也可以选购更多的分区。

如何选择云盘？

创建 Kafka 实例时支持设置数据存储的云盘类型。可设置为 ESSD_FlexPL 或 ESSD_PL0。相比 ESSD_PL0，ESSD_FlexPL 拥有更高的 IOPS 性能，在消息高吞吐以及大量堆积等场景下性能更加稳定。关于不同存储类型的性能说明，请参考云盘规格。

• 对于峰值流量超过 100MB/s 的规格，应使用 ESSD_FlexPL。
• 创建实例后不支持修改存储类型，请谨慎选择云盘类型。

如何删除或退订实例？

对于状态为运行中的实例，如果不再使用，可以清空实例中所有资源和服务，再进行删除或退订操作。

• 对于按量付费实例：清空实例资源后，在实例列表中找到该实例，并在操作列单击删除即可。
• 对于包年包月实例：清空实例资源后，在费用中心找到对应实例的购买订单进行退订。退订相关的费用说明请参考退订管理。

是否支持压缩消息？

消息队列 Kafka版服务端支持收发压缩消息。使用压缩消息之前，您需要在消息队列 Kafka版的客户端启用消息压缩。消息队列 Kafka版支持的消息压缩格式及消耗如下。

是否支持多可用区部署 Kafka 实例？

消息队列 Kafka版支持多可用区部署 Kafka 实例，即支持多 AZ。多可用区部署的实例具备更强的容灾能力，全方位保障集群数据的可靠性和服务的可用性。
在购买 Kafka 实例时，部署方式设置为多可用区部署，并选择 3 个可用区即可实现跨 AZ 容灾。创建实例后，不可修改实例的部署方式，即单可用区部署的实例无法切换为多可用区部署。
对于已购买的 Kafka 实例，您可以在 Kafka 实例的实例详情页签中基本信息区域找到可用区一行，查看可用区数量。如果可用区数量大于 1，表示该实例为多可用区部署的实例。

单 AZ 实例如何切换为多 AZ？

创建实例后，不可修改实例的部署方式，即单可用区部署的实例无法切换为多可用区部署。如果需要使用多可用区实例，建议重新购买 Kafka 实例，并迁移数据到新实例中。

变更实例规格或扩容实例会影响业务吗？

消息队列 Kafka版支持变更实例的计算规格、存储规格和分区数量。其中，各项变更対实例的影响如下：

• 变更计算规格时，服务端节点会依次滚动重启，可能造成客户端与部分节点连接闪断。升级计算规格可能会触发 Topic 分区再均衡，此时后台服务会自动进行数据迁移，推荐选择业务低峰期进行升配操作。
• 增加存储空间、扩容分区数量不会对运行中的业务造成影响。

如何为实例增加分区？

消息队列 Kafka版每个实例规格支持一定范围的分区数量，并提供免费的分区额度。若有业务需求，可以在对应规格的分区范围数量之内购买分区，详细操作请参考升级实例规格。
购买分区之后，可以参考修改 Topic 配置文档，为 Topic 增加分区数量，提高 Topic 的消息处理性能。

是否可以删除分区？

无法直接删除分区，也无法减少 Topic 已经创建的分区数量。但您可以删除 Topic，并创建新的 Topic，此时可以重新设置 Topic 的分区数量。

为什么不能减少分区？

出于开源 Apache Kafka 的限制，Topic 不支持减少分区数。

是否支持缩容？

消息队列 Kafka版的实例降配功能暂时处于邀测阶段，如需使用，请联系客户经理开通白名单。

公网环境必须使用 SASL_SSL 吗？

公网环境可以选择 SASL_SSL 接入点或 SASL_PLAINTEXT 接入点。
您可以根据是否需要 SSL 认证来选择接入点：

• SASL_SSL 接入点：通过 SSL 证书对消息进行鉴权和加密，保障数据传输过程的安全性，防止数据在网络传输过程中被截取或者窃听，相较于普通公网访问方式具备更高的安全性。目前支持客户端对服务端证书的单向认证。
  通过 SASL_SSL 接入点连接 Kafka 实例的操作步骤，请参考使用 SASL_SSL 接入点连接实例。
• SASL_PLAINTEXT 接入点：无需 SSL 证书认证，Kafka 客户端代码配置简单便捷。
  通过 SASL_PLAINTEXT 接入点连接 Kafka 实例的操作步骤，请参考使用 SASL_PLAINTEXT 接入点连接实例。

支持哪些语言的客户端？

火山引擎消息队列 Kafka版支持开源 Apache Kafka 提供的 TCP 协议所有语言客户端 SDK，并为您提供 Java、Go、Python 等各种语言的代码示例以供参考详细说明请参考 概述。

支持的消息体最大是多少？

火山引擎消息队列 Kafka版支持自定义实例和 Topic 粒度的最大消息大小，超出限制的消息无法推送成功。最大消息大小（MessageMaxByte）默认为 10MB，支持设置为 1~12MB。
调整最大消息大小的方式如下：

• 通过修改实例的参数配置，调整实例级别的最大消息大小。详细说明请参考修改实例的参数配置。
• 通过修改 Topic 的参数配置，调整 Topic 粒度的最大消息大小。详细说明请参考修改 Topic 的参数配置。

消息的保留时间是多久？

火山引擎消息队列 Kafka版支持自定义实例和 Topic 粒度的消息保留时长，磁盘容量充足时，超出指定保留时长的消息将被过期清理。消息保留时长（LogRetentionHours）默认为 72 小时，支持设置为 1~2160 小时。
调整消息保留时长的方式如下：

另外，消息队列 Kafka版通过参数自动删除旧消息提供磁盘容量阈值策略，在磁盘容量达到一定水位阈值后，消息队列 Kafka版会根据已设定的磁盘容量阈值策略，删除旧消息或暂停实例的数据写入，避免磁盘使用率达到 100% 而导致 Kafka 实例异常。在这种场景下，消息可能在未超过保留时长的情况下被提前删除，请定期关注实例的磁盘容量，在容量不足时及时升级实例规格。关于磁盘容量阈值策略的详细说明请参考磁盘容量阈值策略。

支持的 Kafka 版本包括哪些？

火山引擎消息队列 Kafka版兼容开源 Kafka 2.2.2 和 2.8.2 版本，推荐您使用对应版本的 Kafka 客户端。
消息队列 Kafka版在版本上完全向下兼容，您也可以选择使用其他版本的开源 Kafka 客户端，例如自建 0.x、1.x 和 2.x 版本的 Kafka 项目，均可以选择 2.x 版本的 Kafka 实例。具体的版本兼容性如下：