CODEWITHSUNDEEP
apache-nifi
Yair Taboch
Yair Taboch

Reputation: 17

Nifi ConsumeKafkaRecord change heartbeat

i have KafkaRecordConsumer_2_0 in nifi and i want to change it's heartbeat interval. is there a way to do so? i've read the documentation and the code and didn't find any.

Upvotes: 0

Views: 190

Answers (1)

maxime G
maxime G

Reputation: 1771

Add a dynamic property in your kafka consumer processor :
key: heartbeat.interval.ms
value: the new value

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.

Upvotes: 2

Related Questions