第 6 章 主题页面


主题 页面显示为 Kafka 集群创建的所有主题。使用此页面检查有关主题的信息。

主题 页面显示主题中分区的整体复制状态,以及主题中分区的数量以及关联的消费者组的数量。该主题使用的整体存储也显示。

警告

内部主题不能修改。您可以从主题页面中返回的主题列表中选择隐藏内部 主题

点击主题名称,在一系列标签页中会显示其他主题信息:

消息
消息显示主题的消息日志。
分区
分区显示主题中每个分区的复制状态。
消费者组
消费者组列出了连接到主题的消费者组和组成员的名称和状态。
配置
配置显示主题的配置。

如果一个主题显示为 Managed,这意味着使用 Apache Kafka Topic Operator 的 Streams 管理,且不会直接在 Kafka 集群中创建。

使用选项卡提供的信息,检查和修改主题的配置。

6.1. 检查主题消息

Messages 选项卡中跟踪特定主题的消息流。Messages 选项卡显示主题的按时间顺序列表。

流程

  1. 在 Apache Kafka 控制台的 Streams 中,点 Kafka 集群的名称,然后点 Topics
  2. 点您要检查的主题名称。
  3. 检查 消息 选项卡上的信息。

    对于每个消息,您可以看到其时间戳(以 UTC)、偏移、键和值。

    单击一条消息,您可以看到完整的消息详情。

    单击 Manage 列 图标(代表两列),以选择要显示的信息。

  4. 单击搜索下拉菜单,再选择高级搜索选项来优化您的搜索。

    选择显示来自指定时间或偏移的最新消息。您可以显示所有分区或指定分区的信息。

    完成后,您可以点击 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
分区选项
选择针对所有分区或特定分区运行搜索。
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat