Member since
06-21-2018
5
Posts
0
Kudos Received
0
Solutions
06-21-2018
03:03 PM
Thanks Bryan, I am providing a schema to the CSVReader and it was simple as using the field name defined in the schema in the Message Key Field property. Cheers, Paul
... View more
06-21-2018
01:14 PM
Hi, I am using the PublishKafkaRecord processor to write messages to a Kafka topic. I am using the CSVReader for the Record Reader property and the AvroRecordSetWriter for the Record Writer property. I would like to set the message key of each message written to Kafka using one of the fields of the csv file by setting the Message Key Field property (see the image below). Please let me know if this is possible or an alternative approach where it can be set on a per record basis? processor.png Many thanks, Paul
... View more
Labels:
- Labels:
-
Apache Kafka
-
Apache NiFi