- Subscribe to RSS Feed
- Mark Question as New
- Mark Question as Read
- Float this Question for Current User
- Bookmark
- Subscribe
- Mute
- Printer Friendly Page
NiFi Publishkafka processor adding custom properties to publishkafka processir
- Labels:
-
Apache Kafka
-
Apache NiFi
Created ‎06-22-2018 02:53 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
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
Created ‎06-22-2018 03:13 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
The documentation for the processor is here:
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.
Created ‎06-22-2018 03:13 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
The documentation for the processor is here:
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.
Created ‎06-22-2018 03:36 PM
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
Thanks a lot, appreciate it!
