检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
公共请求消息头 名称 描述 是否必选 示例 Host 请求的服务器信息，从服务API的URL中获取。值为hostname[:port]。端口缺省时使用默认的端口，https的默认端口为443。 否 使用AK/SK认证时该字段必选。 code.test.com or code.test.com:443
单击Kafka实例的名称，进入实例详情页面。 在左侧导航栏单击“重平衡日志”，进入“重平衡日志”页面。 在页面右上角单击“关闭日志”，弹出确认关闭对话框，单击“确认”，完成重平衡日志的关闭。 关闭重平衡日志只是停止重平衡日志上报功能，LTS控制台的日志组和日志流仍然保留，还会继续收费，如不需要保留该
Kafka实例分内网地址以及公网地址两种网络连接方式。如果使用公网地址，则消息生成与消费客户端需要有公网访问权限，并配置如下安全组。 表1 安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 9094 Kafka客户端所在的IP地址或地址组 通过公网访问Kafka（明文接入）。 入方向 TCP 9095
可能原因：您开启了自动创建消费组功能，且您的业务正在连接该消费组消费消息。所以，如果没有停止您的业务，删除了消费组后，消费消息时还是会自动创建该消费组。 解决办法：关闭自动创建消费组功能，即在Kafka控制台的“配置参数”页面，把“auto.create.groups.enable”设置为“false”，
rise_project Try again. Kafka Manager能否查询到消息的正文？ Kafka Manager WebUI的端口能否修改？ 在Kafka Manager上支持修改Topic的哪些属性？ Kafka Manager和云监控显示的信息不一致 Kafka
收站中，此时实例中的数据尚未被彻底删除，在保留天数内支持从回收站中恢复此实例。超过保留天数的实例会被彻底删除，无法恢复。 回收站策略默认是关闭状态。 回收站功能仅在“华北-北京一”、“华北-北京四”、“华东-上海一”和“华南-广州”上线。 约束与限制 回收站中的按需实例不会收取实例的费用，但是会收取存储空间的费用。
删除指定的实例 功能介绍 删除指定的实例，释放该实例的所有资源。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
请参考以下说明设置请求参数，其他参数根据实际情况设置。 port_id：输入5中获取的其中一个Port ID。 vpc_id：输入7中获取的VPC ID。 server_type：输入“VM”。 client_port：输入“9011”。 server_port：输入“9011”。 protocol：输入“TCP”。
“消费进度”页签中，查看消费组消费的所有Topic列表以及每个Topic的总堆积数和每个分区的消费状态。 集群监控信息/队列监控信息 在“监控”页面，查看实例的监控信息。 前提条件 已配置如表2所示安全组。 表2 安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 9999
import ssl ##连接信息 conf = { 'bootstrap_servers': ["ip1:port1","ip2:port2","ip3:port3"], 'topic_name': 'topic_name', 'sasl_username':
Java客户端常见报错 未关闭域名校验 出现下图的错误信息： 解决方案：检查consumer.properties和producer.properties文件，ssl.endpoint.identification.algorithm参数必须设置为空，关闭域名校验开关。 ssl.endpoint
表示后端收到生产消息请求并复制给所有副本后，才返回客户端。 开启同步复制后，需要在生产者客户端的配置文件或者生产代码中配置acks=all或者-1，否则无效。 当副本数为1时，不能选择同步复制功能。 同步落盘 表示生产的每条消息都会立即写入磁盘，可靠性更高。关闭同步落盘后，生产的消息存在内存中，不会立即写入磁盘。
如何选择Kafka实例存储容量阈值策略？ Kafka服务端支持版本是多少？ Kafka实例的ZK地址是什么？ 创建的Kafka实例是集群模式么？ Kafka实例是否支持修改访问端口？ Kafka实例的SSL证书有效期多长？ 如何将Kafka实例中的数据同步到另一个Kafka实例中？ Kafka实例的SASL_SSL开关如何修改？
华为云计划于2023/05/05 00:00（北京时间）停售分布式消息服务Kafka版2.3.0版本。 下线范围 下线区域：所有区域 下线影响 该版本停售后，新用户将无法进行购买，已购买该版本的用户不受影响，可继续使用扩容等功能。 如您有任何问题，可随时通过工单或者服务热线（4000-955-988或950808）与我们联系。
您只需要在实例管理界面选好规格配置，提交订单。后台将自动创建部署完成一整套Kafka实例。 兼容开源，业务零改动迁移上云 兼容社区版Kafka的API，具备原生Kafka的所有消息处理特性。 业务系统基于开源的Kafka进行开发，只需加入少量认证安全配置，即可使用分布式消息服务Kafka版，做到无缝迁移。 Kafka实例兼容开源社区Kafka
"os" "os/signal" "syscall" ) var ( brokers = "ip1:port1,ip2:port2,ip3:port3" topics = "topic_name" user = "username" password
61\",\"port\":9011,\"port_id\":\"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx\"},\"192.168.0.72\":{\"advertised_ip\":\"192.168.0.72\",\"port\":9011,
是否开启自动创建消费组功能。 2023年4月25日及以后创建的实例支持在控制台修改此参数，在此之前创建的实例默认开启自动创建消费组功能，无法在控制台关闭此功能。 true/false true offsets.retention.minutes 消费位点保留时间是消费位点最大保留时间，从提
objects 所有消费组对应的协调器列表。 表3 coordinators 参数 参数类型 描述 group_id String 消费组ID。 id Integer 对应协调器的broker id。 host String 对应协调器的地址。 port Integer 端口号。 请求示例
修改Kafka的配置参数。 开启/关闭自动创建Topic。 容量阈值策略变更 修改Kafka实例的容量阈值策略。 Kafka动态配置SSL 修改明文接入/密文接入。 配置公网访问 开启/关闭公网访问。 开启Smart Connect 开启Smart Connect功能。 关闭Smart Connect
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
