第 6 章 主题页面
主题 页面显示为 Kafka 集群创建的所有主题。使用此页面检查有关主题的信息。
主题 页面显示主题中分区的整体复制状态,以及主题中分区的数量以及关联的消费者组的数量。该主题使用的整体存储也显示。
内部主题不能修改。您可以从主题页面中返回的主题列表中选择隐藏内部 主题。
点击主题名称,在一系列标签页中会显示其他主题信息:
- 消息
- 消息显示主题的消息日志。
- 分区
- 分区显示主题中每个分区的复制状态。
- 消费者组
- 消费者组列出了连接到主题的消费者组和组成员的名称和状态。
- 配置
- 配置显示主题的配置。
如果一个主题显示为 Managed,这意味着使用 Apache Kafka Topic Operator 的 Streams 管理,且不会直接在 Kafka 集群中创建。
使用选项卡提供的信息,检查和修改主题的配置。
6.1. 检查主题消息 复制链接链接已复制到粘贴板!
从 Messages 选项卡中跟踪特定主题的消息流。Messages 选项卡显示主题的按时间顺序列表。
流程
- 在 Apache Kafka 控制台的 Streams 中,点 Kafka 集群的名称,然后点 Topics。
- 点您要检查的主题名称。
检查 消息 选项卡上的信息。
对于每个消息,您可以看到其时间戳(以 UTC)、偏移、键和值。
单击一条消息,您可以看到完整的消息详情。
单击 Manage 列 图标(代表两列),以选择要显示的信息。
单击搜索下拉菜单,再选择高级搜索选项来优化您的搜索。
选择显示来自指定时间或偏移的最新消息。您可以显示所有分区或指定分区的信息。
完成后,您可以点击 CSV 图标(代表 CSV 文件)下载有关返回的信息。
拒绝搜索
在这个示例中,搜索术语和消息、检索和分区选项被合并:
-
messages=timestamp:2024-03-01T00:00:00Z retrieve=50 partition=1 Error on page load where=value
过滤器在分区 1 中搜索文本"Error on page load"作为消息值,从 2024 年 3 月 1 日开始,并检索到 50 个消息。
- 搜索术语
输入搜索词作为文本(包含单词)以查找特定匹配项,并在消息中定义查找术语 的位置。您可以在消息中的任何位置搜索,或者将搜索范围缩小到键、标头或值。
例如:
-
messages=latest retrieve=100 642-26-1594 where=key
本例在消息键
642-26-1594
中搜索最新的 100 消息。-
- 消息选项
设置返回消息的起点。
latest 从最新的消息开始。
-
messages=latest
-
以 ISO 8601 格式从准确时间和日期开始的时间戳。
-
messages=timestamp:2024-03-14T00:00:00Z
-
从分区中的偏移开始的偏移量。在某些情况下,您可能想要指定没有分区的偏移。但是,最常见的场景是通过特定分区中的偏移搜索。
-
messages=offset:5600253 partition=0
-
UNIX Timestamp 从 Unix 格式的时间和日期开始。
-
messages=epoch:1
-
- 检索选项
设置检索选项。
返回指定数量的消息数。
-
messages=latest retrieve=50
-
持续 实时返回最新消息。点 pause 按钮(由两个垂直线代表)暂停刷新。取消暂停以继续刷新。
-
retrieve=continuously
-
- 分区选项
- 选择针对所有分区或特定分区运行搜索。