检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
用户自定义的advertised_ip_contents键值对。 键是listeners IP。 值是advertised.listeners IP，或者域名。 说明： IP修改未修改项也需填上。 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 success Boolean
表用于用户终端（例如：浏览器）选择。 301 Moved Permanently 永久移动，请求的资源已被永久的移动到新的URI，返回信息会包括新的URI。 302 Found 资源被临时移动。 303 See Other 查看其它地址。 使用GET和POST请求查看。 304 Not
password为服务器证书密码，不可更改，需要保持为dms@kafka。 ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。 SASL_PLAINTEXT：在Kafka命令行工具的“/config”目录中找到“consumer
password为服务器证书密码，不可更改，需要保持为dms@kafka。 ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。 username和password为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。
2024-06-04 本次变更如下： 新增诊断管理相关接口。 2024-03-06 本次变更如下： 新增Smart Connect相关接口。 将转储相关接口移动至历史API。 2024-02-26 本次变更如下： 新增生产消息接口。 2023-11-10 本次变更如下： 新增获取实例配置和修改实例配置接口。
消息被消费后，没有删除，导致Kafka存储空间占满？ 消息被消费后，并不会被删除，只有超过老化时间，才会被删除。 您可以通过减小老化时间或者扩容存储空间，解决此问题。 父主题： Topic和分区问题
Java客户端常见报错 未关闭域名校验 出现下图的错误信息： 解决方案：检查consumer.properties和producer.properties文件，ssl.endpoint.identification.algorithm参数必须设置为空，关闭域名校验开关。 ssl.endpoint
内网SASL_PLAINTEXT连接域名 public_plain_enable Boolean 是否开启公网明文开关 public_plain_address String 公网明文连接地址 public_plain_domain_name String 公网明文连接域名 public_sasl_ssl_enable
重置消费组消费进度到指定位置 功能介绍 Kafka实例不支持在线重置消费进度。在执行重置消费进度之前，必须停止被重置消费组客户端。停止待重置消费组客户端，然后等待一段时间（即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间，默认为1000
内网SASL_PLAINTEXT连接域名 public_plain_enable Boolean 是否开启公网明文开关 public_plain_address String 公网明文连接地址 public_plain_domain_name String 公网明文连接域名 public_sasl_ssl_enable
password为服务器证书密码，不可更改，需要保持为dms@kafka。 ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。 username和password为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。
Connect任务时，如果需要做Kafka实例迁移，可以同时向两个Kafka实例生产消息，源实例中的消息可继续消费，待源实例的消息数据全部被消费完或老化后，业务可迁移到新的Kafka实例。 父主题： 实例问题
a ## spring.kafka.properties.ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭，这里需要保持关闭状态，必须设置为空。 spring.kafka.properties.ssl.endpoint.identification
此不建议使用单副本Topic。 老化时间（小时） 消息的最长保留时间，消费者必须在此时间结束前消费消息，否则消息将被删除。删除的消息，无法被消费。 取值范围：1~720 同步复制 表示后端收到生产消息请求并复制给所有副本后，才返回客户端。 开启同步复制后，需要在生产者客户端的配置
单击Kafka实例名称，进入实例详情页。在左侧导航栏单击“监控与告警 > 监控详情”，进入监控页面。 在实例监控指标页面中，找到需要创建告警的指标项，鼠标移动到指标区域，然后单击指标右上角的，跳转到创建告警规则页面。 在告警规则页面，设置告警信息。 创建告警规则操作，请查看创建告警规则。 设置告警名称和告警的描述。
数据量大的Topic进行分区平衡的时间会比较长，建议根据Topic的消费情况，适当调小Topic老化时间，使得Topic的部分历史数据被及时清理，加快迁移速度。Topic的数据量可以通过监控页面的“队列数据容量”查看，具体步骤请参考查看Kafka监控数据。 分区平衡前的准备工作
topic_id：前提条件中获取的Topic名称。 auto_offset_reset：指定消费者的消费策略。latest表示偏移量自动被重置到最晚偏移量，earliest表示偏移量自动被重置到最早偏移量，none表示向消费者抛出异常。本文以earliest为例。 sasl_mechanism：SASL认证机制。
参数范围 默认值 min.insync.replicas 当producer将acks设置为“all”(或“-1”)时，此配置指定必须确认写入才能被认为成功的副本的最小数量。 1 ~ 3 1 message.max.bytes 单条消息的最大长度。 0 ~ 10485760 单位：字节 10485760
400 DMS.00400045 The instance is not frozen and cannot be unfrozen. 实例没有被冻结，不能进行解除冻结操作。 请查询实例状态 400 DMS.00400046 This security group does not exist
truststore.password=dms@kafka #ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭，这里需要保持关闭状态，必须设置为空。 ssl.endpoint.identification.algorithm=
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
