Apache NiFi 是否直接提供内置机制来在处理事件时捕获 Kafka 主题的消费者组详细信息？

Question

如何在特定消费者组消费 Kafka 事件时触发 API 调用，捕获事件负载、消费者名称、时间戳和组 ID 等详细信息？

目标是捕获以下详细信息并将其发送到 API：

• 事件有效负载：消费事件的确切内容。
• 消费者名称：具体消费者实例的标识符。
• 时间戳：事件被消费的精确时间。
• 消费者组ID：消费者所属消费者组的ID。

我正在寻找一种可靠且有效的方法来实现这一目标。

Answer 1

如果没有明确检查（在代码中），我会说“你不能”

if group.id == "X"

因此，除非您计划为这种类型的逻辑分叉 Nifi kafka 阅读器，或者尝试将其他对处理器链接在一起以提取并测试组 ID 字符串，否则这样的选项不可用尼菲.

最终，听起来您可能想要 Spring-kafka 中的 Spring Slueth 之类的东西，或者只是 Kafka Connect HTTP Sink