客户已付款,订单为什么还卡着?
在订单、支付和处理主题中依次搜索同一个订单 ID,无需为每个主题编写临时 Consumer。
- 01找到等待库存的订单
- 02确认支付已获授权
- 03定位仓库系统超时
ORD-20260812-483921
调查结果 支付成功,但库存预留失败,错误为 WAREHOUSE_TIMEOUT。
为选定主题建立本地索引,即使有数百万条消息,也能快速找到所需内容。 按关键词或详细条件搜索,查看消息内容,并通过 Watch 关注新消息。无需额外部署搜索服务器。
macOS 11+ · Windows 10+ — 免费,无需注册
应用界面也支持简体中文。
下载说明
浏览器可能提示文件“不常下载”,此时可能需要选择保留。首次运行时,Windows 可能显示保护提示,可选择更多信息 → 仍要运行。当前版本尚未进行代码签名。如果下载无法完成,也可尝试无需安装程序的便携版 ZIP。 安装指南
首次打开时,macOS 可能提示无法验证开发者。请在系统设置 → 隐私与安全性 → 仍要打开中允许打开。当前版本尚未经过 Apple 公证。 安装指南
从这些场景开始
以下只是部分示例。您可以使用系统中的标识符、字段、关键词或时间范围,调查所需的 Kafka 消息。 尤其适合已将业务运行数据保存在 Kafka 中,但不需要承担整套 ELK 部署成本和维护负担的独立开发者与小型团队。
在订单、支付和处理主题中依次搜索同一个订单 ID,无需为每个主题编写临时 Consumer。
ORD-20260812-483921
调查结果 支付成功,但库存预留失败,错误为 WAREHOUSE_TIMEOUT。
如果 Nginx 和应用日志已收集到 Kafka,可在本地建立索引,缩小故障时间范围,再沿 trace ID 追踪原因。
P.status = "502*" AND P.path = "/api/checkout*" AND P.method = "POST*"
调查结果 checkout 服务的支付连接池已耗尽: 50 / 50 个连接正在使用,184 个请求等待中。
Kaflow Search 持续同步主题时,支付运维人员可通过轻量的关键词 Watch 观察所需消息。
payment_failedpayment_failed
新匹配消息 订单 ORD-20260819-WATCH03 因支付网关在 3000 毫秒后超时而失败。
利用最后保存的本地索引查看故障前收集的消息,找出仍需人工处理的任务。
PENDING
调查结果 支付已获授权,但履约尚未开始。订单状态仍为 PENDING ,需要人工审核。
使用适合您系统的线索。Kaflow Search 可直接使用您已有的主题和字段。
标识符 · 字段 · 关键词 · 时间范围
用于您的调查 这四个场景仅作示例。您可以将同样的本地搜索流程用于团队运营的 Kafka 数据。
实际应用界面
横向滚动以查看实际界面。




Kafka 消息搜索 & 关键词 Watch
保持选定主题同步,在新消息到达时观察已保存的关键词。无需额外部署监控系统,即可轻松发现日常运维中关心的信号。
仅为所需主题建立索引,在可配置的本地存储上限内搜索数百万条消息。
对键、消息头、嵌套 JSON 字段和时间范围组合使用 AND、OR、NOT 条件。
支持 JSON、Avro 和 Protobuf,可配合 Confluent Schema Registry 使用。
消息与索引保存在您的电脑上。Kaflow Search 以只读方式访问 Kafka。
不必再逐条翻看 Kafka 消息。
现在还不打算安装?没关系。
如果觉得以后可能用得上,可以先在 GitHub 上点个 Star,方便需要时找到。您的关注也是我们持续改进的动力。使用 Kafka 的过程中,总会遇到需要查找某条消息的时候。
在 GitHub 上为项目点 Star