检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
扩容过程中涉及数据迁移吗? 扩容过程中不会迁移数据。 父主题: 实例规格变更问题
r开启幂等时(生产者客户端3.0及之后的版本默认开启幂等),生产消息会在服务端创建生产者状态对象,若频繁创建producer,会导致服务端创建大量生产者状态对象后无法及时回收,服务端内存占用飙升,进而导致服务端性能急剧下降。如果不需要使用幂等功能,请将“enable.idempotence”设置为“false”。
查询Topic流控配置 - ShowKafkaTopicQuota 功能介绍 该接口用于查询Topic级别的流控任务。 调用方法 请参见如何调用API。 授权信息 账号具备所有API的调用权限,如果使用账号下的IAM用户调用当前API,该IAM用户需具备调用API所需的权限。 如
关闭Kafka Manager - CloseKafkaManager 功能介绍 关闭Kafka Manager,相应的原来开放出的management相关接口也将不可用。 调用方法 请参见如何调用API。 授权信息 账号具备所有API的调用权限,如果使用账号下的IAM用户调用当
Kafka生产消息 - SendKafkaMessage 功能介绍 在控制台发送指定消息到Kafka实例。 调用方法 请参见如何调用API。 授权信息 账号具备所有API的调用权限,如果使用账号下的IAM用户调用当前API,该IAM用户需具备调用API所需的权限。 如果使用角色与
查询实例标签 - ShowKafkaTags 功能介绍 查询实例标签。 调用方法 请参见如何调用API。 授权信息 账号具备所有API的调用权限,如果使用账号下的IAM用户调用当前API,该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权,具体权限要求请参见权限和授权项。
删除Smart Connect任务 - DeleteConnectorTask 功能介绍 删除Smart Connect任务。 调用方法 请参见如何调用API。 授权信息 账号具备所有API的调用权限,如果使用账号下的IAM用户调用当前API,该IAM用户需具备调用API所需的权限。
开启公网访问后,在哪查看公网IP地址? 在Kafka控制台,单击Kafka实例名称,进入实例详情页面。在“概览”页签,查看公网IP地址(即“公网连接地址”)。 如果您需要连接Kafka实例,请参考连接Kafka。 父主题: 连接问题
Kafka实例的SSL证书有效期多长? Kafka实例开启SASL_SSL时,需进行单向认证,证书有效期足够长(超过15年),客户端不需要关注证书过期风险。 查看SSL证书有效期的方法如下: 解压从Kafka实例控制台下载的压缩包,获取压缩包中的“phy_ca.crt”。 双击“phy_ca
使用主账号或者“admin”用户组中的子账号登录Kafka控制台。 在管理控制台左上角单击,选择区域。 在左侧导航栏选择“服务授权”,进入“服务授权”页面。 勾选“访问费用中心服务”,单击“更新授权”。 授权成功后,会在IAM中创建名为“dms_admin_trust”的委托。 “dms_a
“子网”保持默认设置。 在“内网IP地址”中,选择“自动分配”或者“手动选择”。 自动分配:系统自动分配子网中可用的IP地址。 手动选择:在下拉框中为新扩容代理勾选指定的IP地址。如果指定的IP地址数量少于代理数量时,系统会自动为剩余代理分配IP地址。 单击“下一步”,进入变更信息确认页面。 确认扩容信息无误后,单击“提交”。
实例升级 - UpgradeInstance 功能介绍 实例内核升级。 调用方法 请参见如何调用API。 授权信息 账号具备所有API的调用权限,如果使用账号下的IAM用户调用当前API,该IAM用户需具备调用API所需的权限。 如果使用角色与策略授权,具体权限要求请参见权限和授权项。
Object 参数解释: 扩展配置。 topic_type Integer 参数解释: Topic类型。 取值范围: 0:普通Topic。 1:系统(内部)Topic。 topic_other_configs Array of topic_other_configs objects 参数解释:
暂停Smart Connect任务 - PauseConnectorTask 功能介绍 暂停Smart Connect任务。 调用方法 请参见如何调用API。 授权信息 账号具备所有API的调用权限,如果使用账号下的IAM用户调用当前API,该IAM用户需具备调用API所需的权限。
修改自动创建Topic的配置,会触发重启吗? 开启或者关闭“Kafka自动创建Topic”,会导致Kafka重启。 父主题: Topic和分区问题
购买实例时选择的单AZ,怎样可以扩展为多AZ? 已购买的实例无法扩展AZ,请重新购买多AZ的实例。 父主题: 实例问题
生产消息数不为0,为什么生产速率为0? 消息生产速率的原始指标数据为每分钟上报一次,但是它的单位为“个/秒”,所以消息生产速率=一分钟内生产的消息数/60,其值向下取整。当一分钟内生产的消息数小于60个时,生产速率会显示为0。 父主题: 监控告警问题
正常情况下消费组内加入新的消费者或老的消费者退出都会导致Rebalance,这种情况是无法避免的。但是某些特殊情况下,消费者会被服务端认为异常从而被踢出消费组,此时可能会导致消费异常,需要重点关注。 消费者被服务端认为异常从而被踢出消费组的场景如下: 未能及时发送心跳请求。 消费者以设置的heartbeat.interval
扩容/缩容过程中生产消息失败 可能原因:在扩容/缩容代理规格的过程中,代理采用滚动重启的方式进行实例变更。在重启过程中,分区Leader会进行切换,此时生产客户端的元数据缓存中保存的分区Leader为旧分区Leader ID,仍然会向旧分区Leader发送消息,导致生产消息失败。
前提条件 已准备一台Linux系统的服务器,并安装Java Development Kit 1.8.111或以上版本,配置JAVA_HOME与PATH环境变量。 实例已开启Kafka SASL_SSL。 步骤一:制作客户端验证服务端的证书 登录Linux系统的服务器,执行以下命令,生成server