已启动NiFi的Consume Kafka进程，如何查看已消费的Kafka消息？

嘿，我之前刚解决过一模一样的问题！既然你的Consume Kafka进程已经正常运行了，给你分享几个实用的方法来查看消费到的消息内容：

1. 用临时处理器直观输出（最适合测试） #

• 给你的Consume Kafka处理器添加一个LogAttribute处理器，连接两者的数据流关系。打开LogAttribute的配置界面，找到Log Payload选项，把它设为true，然后启动这个处理器。
• 之后回到NiFi主界面，点击右上角的「Logs」按钮，或者从菜单栏进入「Controller Settings」→「Logs」页面，就能在日志里看到每条消费到的消息的完整payload内容了。
• 要是你想把消息保存下来慢慢看，也可以用PutFile处理器替代LogAttribute，配置好本地的输出目录，启动后就能在对应文件夹里看到消息文件了。

2. 通过数据溯源（Provenance）查看 #

• 在NiFi画布上右键点击你的Consume Kafka处理器，选择View Data Provenance。
• 在弹出的溯源页面里，你可以通过时间范围、事件类型来筛选，找到标记为RECEIVE的事件——这些就是从Kafka消费到的消息记录。
• 点击任意一条RECEIVE事件，切换到Content标签页，就能直接预览消息的原始内容，还能根据消息格式选择文本、JSON等不同的预览方式。

3. 查看处理器状态与核心日志 #

• 点击Consume Kafka处理器，切换到底部的Status标签页，这里能看到已消费消息数、处理吞吐量、分区偏移量等统计数据，先确认进程确实在正常消费。
• 要是需要更详细的消费细节，可以去NiFi的核心日志文件（默认路径是nifi/logs/nifi-app.log）里搜索ConsumeKafka相关的日志条目，里面会记录消费的主题、分区、偏移量，开启调试级别的话还能看到部分消息内容。

小提示 #

测试环境用LogAttribute/PutFile没问题，但生产环境尽量不要长期开启LogAttribute的日志payload，避免占用过多日志存储空间，用Provenance或者按需查看核心日志会更稳妥。

内容的提问来源于stack exchange，提问作者hasherBaba