Apache nifi 作为消费者接收来自 kafka 主题的消息

【问题标题】：Apache nifi as cosumer to recieve messages from kafka topicApache nifi 作为消费者接收来自 kafka 主题的消息
【发布时间】：2020-02-17 22:40:44
【问题描述】：

我有一个场景，我必须在 Nifi Kafka 消费者处理器中使用通过本地调用的 Kafka 生产者 Jar 发送的消息中的消息 ..我可以在 kafka cosumer 控制台中使用消息，但不能在 Nifi 中使用......如何查看如果消息是 json 格式，则 nifi 消费者中的消息

【问题讨论】：

【解决方案1】：

设置您的消费 kafka 处理器并将其链接到停止的处理器。

右键单击队列>列出队列>查看详细信息>查看。

【讨论】：

我已经完成了这个过程..但是仍然无法检索从kafka生产者java jar发送的任何消息..您可以上传要在nifi中的消费者kafka记录中设置的属性以接收来自生产者java的json消息罐子
不能，因为它取决于您的 kafka 配置。你看到任何关于 kafka-console-consumer 的消息了吗？
是的消费者能够接收消息.. 但不是 nifi 消费者 kafka
所以向我们展示你的命令行并使用KafkaRecord处理器配置。