检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
消费组消费的其他Topic进行诊断。 操作流程 图1 消息积压诊断流程图 步骤一：诊断前检查 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
数相同。购买弹性IP地址的操作指导请参考申请弹性公网IP。 步骤一：获取Kafka实例的信息 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
如果消费组从未提交过offset，当Kafka实例重启后，该消费组会被删除。 创建Kafka消费组 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
Integer 当次查询返回的最大topic个数，默认值为10，取值范围为1~50。 sort_key 否 String 排序规则： topic：按topic名称排序。 partition：按分区数排序。 messages：按消息数量排序，默认方式。 sort_dir 否 String 排序方式。
前提条件 Kafka实例的状态为“运行中”时，才能修改实例的基本信息。 查看Kafka实例的详细信息 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
: = + - @ 创建实例时设置的标签值，首尾字符不能为空格。 配置Kafka实例标签 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
eeper数据的存储，因而实际可用存储会小于购买存储。 其中，副本数在创建Topic时可以选择，默认为3副本存储。如果开启了Kafka自动创建Topic功能，自动创建的Topic默认为3副本，副本数可以通过“配置参数”页签中的“default.replication.factor”修改。
从控制台获取项目ID 在调用接口的时候，部分URL中需要填入项目ID（project_id），所以需要先在管理控制台上获取到项目ID。 项目ID获取步骤如下： 登录管理控制台。 鼠标悬停在右上角的用户名，选择下拉列表中的“我的凭证”。 在“API凭证”页面的项目列表中查看项目ID。
重复1~3，扩容/缩容Broker 2的规格。 图2 扩容/缩容代理规格过程 变更Kafka集群实例规格 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
在添加订阅后，对应的订阅终端会收到订阅通知，用户要选择确认订阅，后续才能收到告警信息。 通知周期 保持默认，即如果触发告警，每天发送告警通知。 生效时间 告警规则仅在生效时间内发送通知消息，保持默认。 通知内容模板 选择“默认”。 通知策略创建成功后，返回“创建告警规则”页面。 在“通知策略”后，单击，然后在下拉框中选择新创建的通知策略。
"instance_id" : "20c6b355-5d95-45ef-b476-e38bcccce0d7", "url" : "https://console.xxx.xxx.com/dms/?engine=all®ion=xxx&locale=xxx#/queue/manager/newKafkaList"
分区总数。 topics Array Topic列表。 表3 参数说明 参数 类型 说明 policiesOnly Boolean 是否为默认策略。 id String Topic名称 replication Integer 副本数，配置数据的可靠性 partition Integer
Kafka实例的状态为“运行中”时，才能升级Kafka实例内核版本。 升级Kafka实例内核版本 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
schema_generator类，默认为"io.confluent.connect.storage.hive.schema.DefaultSchemaGenerator"。（仅目标端类型为OBS时会显示） partitioner_class String partitioner类，默认"io.confluent
些控制消息也会生产到该Topic中， 且它们对消费者不可见，从而造成offset不连续的现象。 Kafka生产者客户端3.0及之后的版本会默认开启幂等，如果不需要使用该功能，请将“enable.idempotence”设置为“false”。 父主题： 消息问题
schema_generator类，默认为"io.confluent.connect.storage.hive.schema.DefaultSchemaGenerator"。（仅目标端类型为OBS时会显示） partitioner_class String partitioner类，默认"io.confluent
Boolean 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效，默认关闭。 sync_message_flush Boolean 是否使用同步落盘。默认值为false。同步落盘会导致性能降低。 external_configs Object 扩展配置。
Kafka Manager如何修改Topic的分区Leader？ 实例版本在控制台和Kafka Manager上显示不一致？ 为什么实例中存在默认名为__trace和__consumer_offsets的Topic？ 客户端删除消费组后，在Kafka Manager中仍可以看到此消费组？
export PATH=$JAVA_HOME/bin:$PATH 执行source .bash_profile命令使修改生效。 弹性云服务器默认自带的JDK可能不符合要求，例如OpenJDK，需要配置为Oracle的JDK，可至Oracle官方下载页面下载Java Development
、06:00:00、10:00:00、14:00:00和18:00:00。 该参数不能单独为空，若该值为空，则结束时间也为空。系统分配一个默认开始时间02:00:00。 maintain_end String 否 维护时间窗结束时间，格式为HH:mm:ss。 维护时间窗开始和结束
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
