检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
topic分区数，设置消费的并发数。 默认值为3，取值范围为1~100。 replication Integer 否 副本数，配置数据的可靠性 默认值为3，取值范围为1~3。 sync_replication Boolean 否 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效。
应用场景 在分布式消息服务Kafka版提供的原生Kafka SDK中，消费者可以自定义拉取消息的时长，如果需要长时间的拉取消息，只需要把poll(long)方法的参数设置合适的值即可。但是这样的长连接可能会对客户端和服务端造成一定的压力，特别是分区数较多且每个消费者开启多个线程的情况下。
在弹出的“重置消费进度”对话框中，参考表1，设置重置消费进度参数。 表1 重置消费进度参数说明 参数 说明 重置类型 选择重置类型： 时间：重置消费进度到指定的时间。 偏移量：重置消费进度到指定的偏移量。 一键重置消费进度只支持重置消费进度到指定时间。 时间 当“重置类型”为“时间”时，需要设置此参数。 选择
Kafka实例不支持在线重置消费进度。在执行重置消费进度之前，必须停止被重置消费组客户端。停止待重置消费组客户端，然后等待一段时间（即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间，默认为1000毫秒）后，服务端才认为此消费组客户端已下线。 调用方法 请参见如何调用API。
ServiceUnavailable 被请求的服务无效。 建议直接修改该请求，不要重试该请求。 504 ServerTimeout 请求在给定的时间内无法完成。客户端仅在为请求指定超时（Timeout）参数时会得到该响应。 505 HTTP Version not supported 服务器不支持请求的HTTP协议的版本，无法完成处理。
消息堆积数图表 在“创建告警规则”页面，设置告警名称。告警名称需要符合命名规则：只能由中文、英文字母、数字、下划线、中划线组成。 图3 设置告警名称 在“创建告警规则”页面，设置监控范围。保持当前设置，无需修改。 在“创建告警规则”页面，设置告警策略。 图4 设置告警策略 告警策略：连续1次
failed 表示消费组内的某一个消费者超时退出，一般触发场景是消费者长时间没有与服务端通信导致，比如处理消息耗时太久阻塞等。 对文件中每次Preparing到Stabilized完成的时间进行计算得到以下结果图。图中时间为UTC+0时间，对应北京时间需要加8小时。 图1 消费组rebalance图
为true，execute_at字段非空。 execute_at 否 Long 定时时间，格式为Unix时间戳，单位为毫秒 time_estimate 否 Boolean 设为true表示执行时间预估任务，false为执行重平衡任务。 表3 PartitionReassignEntity
法请参考修改配置参数。 原因如下：Kafka通过offsets.retention.minutes参数控制消费组中offsets保留时间，在此时间内如果没有提交offset，offsets将会被删除。Kafka判定消息组中没有在线的消费者（如empty状态），且没有offsets时，将会删除此消费组。
文件迁移到新的Kafka。主要涉及到以下2类场景： 业务上云且不希望业务有中断。 在上云过程中，连续性要求高的业务，需要平滑迁移，不能有长时间的中断。 在云上变更业务部署。 单AZ部署的Kafka实例，不具备AZ之间的容灾能力。用户对可靠性要求提升后，需要迁移到多AZ部署的实例上。
概述 Kafka实例完全兼容开源Kafka协议，可以直接使用kafka开源客户端连接。如果“kafka安全协议”设置为“SASL_SSL”，则在开源客户端基础上使用云服务提供的证书文件。 本指南主要介绍实例连接信息的收集，如获取实例连接地址、Topic名称等，然后提供Java、Python和Go等语言的连接示例。
消息被消费后，没有删除，导致Kafka存储空间占满？ 消息被消费后，并不会被删除，只有超过老化时间，才会被删除。 您可以通过减小老化时间或者扩容存储空间，解决此问题。 父主题： Topic和分区问题
查GC日志是否存在长时间FullGC的情况。该场景可能会导致心跳线程阻塞，服务端检查心跳失败，进入Rebalance状态。 解决方法：如果存在长时间FullGC的情况，需要您排查客户端相关问题（FullGC可能是客户端存在内存泄露）。 场景二：消费者消费时间间隔过长 排查思路：
实例负载为30MB/s），建议不设置带宽限制。如果需要设置带宽限制，建议该参数值不小于待分区平衡Topic的总生产带宽 * 待分区平衡Topic的最大副本数。 带宽限制值的估算方法，请参考带宽限制值估算方法。 执行时间 选择分区平衡任务执行的时间。 立即执行：表示立即执行分区平衡任务。
SASL_SSL功能，此时Topic支持配置ACL权限。在Kafka控制台的“Topic管理”页面，在需要设置用户权限的Topic所在行，单击“设置用户权限”，为用户设置不同的权限。 具体操作请参考设置Topic权限。 父主题： Topic和分区问题
在左侧导航栏单击“后台任务管理”，进入后台任务管理页面。 在“后台任务”/“定时任务”页签，单击时间段下拉框，选择搜索时间，在搜索框中输入关键字，按“Enter”，界面显示相应时间段内启动的任务。 在后台任务管理页面，您还可以执行以下操作： 单击，刷新任务状态。 单击“删除”，
> 导出全部数据到XLSX”，导出全部Topic列表。 Topic列表中包含如下信息：Topic名称、分区数、副本数、老化时间、是否同步复制或同步落盘、消息时间戳类型、批处理消息最大值和描述信息。 父主题： Topic管理
最小的offset，如果大于最大的offset，则重置到最大的offset。 timestamp Long 重置的消费进度到指定时间，格式为unix时间戳。如果传入timestamp早于当前最早的timestamp，则重置到最早的timestamp，如果晚于最晚的timestamp，则重置到最晚的timestamp。
如果您持有多台到期日不同的Kafka实例，可以将到期日统一设置到一个日期，便于日常管理和续费。 图5展示了用户将两个不同时间到期的资源，同时续费一个月，并设置“统一到期日”后的效果对比。 图5 统一到期日 更多关于统一到期日的规则请参见如何设置统一到期日。 父主题： 续费
动创建Topic，然后才能进行生产消息和消费消息。 创建Topic后，您可以根据业务需要修改Topic的老化时间。 支持区域： 全部 创建Topic 修改Topic老化时间 修改Topic分区数 变更实例规格 Kafka实例创建成功后，您可以根据业务需要，扩容基准带宽、代理个数、存储空间、代理规格，或者缩容代理规格。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
