Блог

у меня есть KafkaRecordConsumer_2_0 в nifi, и я хочу изменить интервал сердцебиения. есть ли способ сделать это? я прочитал документацию и код и ничего не нашел.

Добавьте динамическое свойство в ваш потребительский процессор kafka :
ключ: heartbeat.interval.ms
значение: новое значение

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

Динамические свойства:

Динамические свойства позволяют пользователю указывать как имя, так и значение свойства.

Name: имя свойства конфигурации Kafka.
Значение: значение заданного свойства конфигурации Kafka.