Nifi消费KafkaRecord变化心跳

Question

我在 nifi 中有 KafkaRecordConsumer_2_0，我想更改它的心跳间隔。 有办法吗？ 我已经阅读了文档和代码，但没有找到。

Answer 1

在您的 kafka 消费者处理器中添加动态 属性 :
键：heartbeat.interval.ms
值：新值

https://nifi.apache.org/docs/nifi-docs/components/nifi-docs/components/org.apache.nifi/nifi-kafka-2-0-nar/1.9.0/org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_2_0/index.html

Dynamic Properties:

Dynamic Properties allow the user to specify both the name and value of a property.

Name: The name of a Kafka configuration property.
Value: The value of a given Kafka configuration property.