操作场景
当任务在健康的状态时,数据正常转储, Topic 有新增的消息写入时,可以在对应 Topic 中查看到新增的消息。当您遇到消息消费异常,也可以通过查询异常消息来排查问题。
本文介绍在 CKafka 连接器中查看 Topic 中新增消息的操作方法。
操作步骤
在 CKafka 连接器中查看 Topic 中新增消息有两个入口:
入口一:登录 CKafka 控制台,在弹性 Topic 列表页面找到要查看的 Topic,单击Topic 的“ID”,进入基本信息页面,在页面上方单击查看消息页签。
入口二:登录 CKafka 控制台,在连接器 > 任务列表页面找到要查看的任务,单击任务的“ID”,进入基本信息页面,在页面上方单击查看消息页签。
进入查看消息页面后,选择好要查看的 Topic 和分区,可以查看最近的5条、20条、50条和100条消息。