André Alves created NIFI-13408:
----------------------------------
Summary: Dynamically Update Kafka Topic in ConsumeKafka_2_6
Processor
Key: NIFI-13408
URL: https://issues.apache.org/jira/browse/NIFI-13408
Project: Apache NiFi
Issue Type: New Feature
Components: Extensions
Reporter: André Alves
The main goal is to enhance the ConsumeKafka_2_6 processor to dynamically
change the Kafka topic based on incoming flowfile attributes. This allows the
processor to be more flexible and adaptable to varying data flows by updating
the Kafka topic as specified by the attributes in the flowfiles. To implement
this new feature, the following changes were made:
* Updated the processor to be able to receive incoming flowfiles.
* Enabled the "Topic Name(s)" property to support expression language,
allowing it to take values from flowfile attributes.
* Added a new entry named flowNames to the "Topic Name Format" property. When
this entry is chosen, the processor will determine the Kafka topic based on the
flowfile attribute defined in the "Topic Name(s)" property using expression
language.
* Created a JUnit test to cover this new feature.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
