检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
磁盘类型选择“超高I/O”，磁盘大小设置为“100GB”。 图3 设置实例规格和存储空间 设置实例网络环境信息，如图4所示，配置详情请参考表4。 表4 设置实例网络环境信息 参数 说明 虚拟私有云 虚拟私有云在Kafka实例创建完成后，不支持修改。 选择准备工作中设置好的虚拟私有云。 子网
00:00。 security_group_id String 否 安全组ID。 retention_policy String 否 容量阈值策略。 支持两种策略模式： produce_reject: 生产受限 time_base: 自动删除 enterprise_project_id
获取方法如下：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。 retention_policy 否 String 容量阈值策略。 支持两种策略模式： produce_reject: 生产受限 time_base: 自动删除 enterprise_project_id
测超过预算阈值时，自动发送通知给指定消息接收人。企业还可以创建预算报告，定期将指定预算进展通知给指定消息接收人。 例如企业需要创建一个Kafka实例的按需成本预算，每月预算金额为2000元，当预测金额高于预算金额的80%时发送预算告警。那么，创建的预算如下： 图4 设置预算信息 图5
SASL_SSL功能，此时Topic支持配置ACL权限。在Kafka控制台的“Topic管理”页面，在需要设置用户权限的Topic所在行，单击“设置用户权限”，为用户设置不同的权限。 具体操作请参考设置Topic权限。 父主题： Topic和分区问题
消息超过老化时间，消息仍存在的原因 问题现象：消息超过设置的老化时间（如果Topic已经设置了老化时间，此时“配置参数”中的log.retention.hours值将不对此Topic生效。仅在Topic中未设置老化时间时，“配置参数”中的log.retention.hours值才会对此Topic生效。），消息仍存在。
您需要通过公网地址访问Kafka实例时，可开启实例的公网访问功能，并设置公网带宽。当开启成功后，您还可以根据需要修改公网带宽的大小，当前仅支持带宽扩容，不支持缩容。 部分区域不支持“基准带宽”为“100MB/s”的Kafka实例开启公网访问，具体以控制台为准。 支持区域： 全部 设置实例公网访问 消息查询 您可以查
Kafka支持减少分区数吗？ Kafka不支持减少分区数，您可以通过删除原先的Topic，然后创建新Topic，重新设置分区数。 父主题： Topic和分区问题
重置Kafka Manager密码 如果您忘记了创建实例时设置的Kafka Manager密码，通过重置Manager密码功能，重新设置一个新的密码，可使用新密码登录Kafka Manager。 2023年5月17日及以后创建的实例不提供重置Kafka Manager密码功能。 前提条件
为什么消息创建时间显示1970？ 消息创建时间是由生产客户端在生产消息时通过CreateTime指定的，如果生产消息时没有设置此参数，消息创建时间会默认为1970。 父主题： 消息问题
请注意查看该可用区是否有资源。 创建Kafka实例，支持节点部署在1个或3个及3个以上的可用区。在为节点指定可用区时，用逗号分隔开。参数设置参考如下示例。 一个可用区："available_zones": [ "a0865121f83b41cbafce65930a22a6e8"
Kafka实例的Topic数量是否有限制？ Topic数量和Topic总分区数、每个Topic的分区数有关，Kafka实例对Topic总分区数设置了上限，当达到上限后，会导致用户无法继续创建Topic。 不同规格配置的Topic总分区数不同，如下表所示。 表1 Kafka集群实例规格
Topic的相关业务。 已开启密文接入的实例，“allow.everyone.if.no.acl.found”设置为“false”时，初始用户（即首次开启密文接入时设置的用户）可以通过客户端删除Topic，其他用户无法通过客户端删除Topic。 前提条件 只有运行中的实例才可以删除Topic。
概述 Kafka实例完全兼容开源Kafka协议，可以直接使用kafka开源客户端连接。如果“kafka安全协议”设置为“SASL_SSL”，则在开源客户端基础上使用云服务提供的证书文件。 本指南主要介绍实例连接信息的收集，如获取实例连接地址、Topic名称等，然后提供Java、Python和Go等语言的连接示例。
未开启IPv6的实例，安全协议支持在控制台修改。先在Kafka实例的详情页的“连接信息”区域，关闭密文接入，然后再开启密文接入，此时可以重新设置安全协议。 已开启IPv6的实例，实例创建后，不支持修改安全协议。 父主题： 实例问题
"storage_spec_code": "dms.physical.storage.high.v2" } name：实例名称，由您自行定义。 engine：消息引擎，设置kafka。 engine_version：消息引擎的版本。 broker_num：代理个数。 storage_space：消息存储空间，
List）权限管理，您可以在Topic中为不同的用户设置不同的生产消费消息的权限，以达到用户之间的权限隔离。 本章节主要介绍Kafka实例开启密文接入后，如何创建用户、重置用户密码、修改用户信息和删除用户。创建用户后，对Topic进行用户授权的操作，请参见设置Kafka Topic权限。 在控制
ms的错误，如下图所示。 问题解决措施 以下三种措施都可以解决此问题，请根据实际情况任意选择一种。 升级Kafka客户端的版本到2.7或以上版本，并设置“socket.connection.setup.timeout.ms”大于1s，且小于“request.timeout.ms/Kafka服务端节点数”。
Sarama客户端消息最大处理时间（MaxProcessingTime）默认值为100ms，超过最大处理时间可能导致消费者无法消费。 当消费位点重置策略设置为Oldest(earliest)时，当客户端重启时，偏移量重置后可能从最小位点开始重复消费所有消息。 消费者同时订阅多个Topic时，部分分区可能无法消费到消息。
量为2到4的消息。 请注意以下几点： 如果“偏移量”设置为“-1”，表示删除分区中所有的消息。 如果您输入的偏移量不在指定分区的最早偏移量和最晚偏移量之间，消息将不会被删除。 如果需要删除多个分区的消息，单击“添加分区”，设置需要删除消息的分区和偏移量。每次最多可选择10个分区。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
