question Re: NiFi Publishkafka processor adding custom properties to publishkafka processir in Archives of Support Questions (Read Only)

NiFi Publishkafka processor adding custom properties to publishkafka processir

dhieru — Fri, 22 Jun 2018 21:53:51 GMT

Hi All,

I am trying to tune my publish kafka processor and want to add custom properties such as batch.size and linger.ms

however I do not see any mention of them in the source code of the processor.

So if I add these properties will the publishkafka processor honor it and use it when publishing?

How wil it work?

Thanks

Dhiren

Re: NiFi Publishkafka processor adding custom properties to publishkafka processir

bbende — Fri, 22 Jun 2018 22:13:50 GMT

The documentation for the processor is here:

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-9-nar/1.6.0/org.apache.nifi.processors.kafka.pubsub.PublishKafka/index.html

It says...

Dynamic Properties:

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

The name of a Kafka configuration property.

The value of a given Kafka configuration property.

These properties will be added on the Kafka configuration after loading any provided configuration properties. In the event a dynamic property represents a property that was already set, its value will be ignored and WARN message logged. For the list of available Kafka properties please refer to: http://kafka.apache.org/documentation.html#configuration.

Re: NiFi Publishkafka processor adding custom properties to publishkafka processir

dhieru — Fri, 22 Jun 2018 22:36:13 GMT

@Bryan Bende

Thanks a lot, appreciate it!