检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
com.huaweicloud.sdk.kafka.v2.model.*; public class ResetManagerPasswordSolution { public static void main(String[] args) { // The
如果Topic中的消息在进行下一次数据同步前，已经全部老化，此时实际是没有待同步的Kafka数据，但是Kafka数据同步监控指标使用的是包含老化数据的offset值，“待同步Kafka数据量”会显示老化的消息数。 维度 Key Value kafka_instance_id Kafka实例 kafka_broker
按照提示信息输入客户端证书的Truststore密码，并记录此密码。此密码用于客户端连接Kafka实例时，配置文件中“ssl.truststore.password”参数的值。 密码需要满足如下要求： 8~32个字符。 至少包含以下字符中的3种：大写字母、小写字母、数字、特殊字符`~!@#$%^&*()-_=+\|[{}]:'"
Array<Object> 标签列表。 表3 tags 参数 参数类型 描述 key String 标签的键。 value String 标签的值。 响应示例 { "name": "kafka-l00230526", "engine": "kafka", "port":
access_user String 实例访问用户名。 order_id String 订单ID，只有在包周期计费时才会有order_id值，其他计费方式order_id值为空。 maintain_begin String 维护时间窗开始时间，格式为HH:mm:ss。 maintain_end String
选择“不开启”，即生产的消息存在内存中，不会立即写入磁盘。 消息时间戳类型 选择“CreateTime”，即生产者创建消息的时间。 批处理消息最大值（字节） Kafka允许的最大批处理大小，如果在生产客户端配置文件或代码中启用消息压缩，则表示压缩后的最大批处理大小。 输入“10485760”。
参数 是否必选 参数类型 描述 topic 否 String topic名称。 partition 是 Integer 分区编号，默认值为-1，若传入值为-1，则重置所有分区。 message_offset 否 Long 重置消费进度到指定偏移量。 如果传入offset小于当前最小的
参数 是否必选 参数类型 描述 topic 否 String topic名称。 partition 是 Integer 分区编号，默认值为-1，若传入值为-1，则重置所有分区。 message_offset 否 Long 重置消费进度到指定偏移量。 如果传入offset小于当前最小的
jks”需要存放到客户端中，并记录存放路径，此路径用于客户端连接Kafka实例时，配置文件中“ssl.truststore.location”参数的值。 步骤二：制作服务端验证客户端的证书 登录Linux系统的服务器，执行以下命令，生成client.keystore.jks证书的孵化器。 keytool
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
