I've tried a couple different configurations of CSVReader / JsonRecordSetWriter with the QueryRecord processor, and I don't think I quite have the usage down yet.
Can someone give a basic example configuration in the following 2 scenarios? I followed most of Matt Burgess's response to the post titled "How to use ConvertRecord Processor", but I don't think it tells the whole story. 1) QueryRecord, converting CSV to JSON, using only the CSV headers to determine the schema. (I tried selecting Use String Fields from Header in CSVReader, but the processor really seems to want to use the JsonRecordSetWriter to determine the schema) 2) QueryRecord, converting CSV to JSON, using a cached avro schema. I imagine I need to use InferAvroSchema here, but I'm not sure how to cache it in the AvroSchemaRegistry. Also not quite sure how to configure the properties of each controller service in this case. Any help would be appreciated. Joe -- I know what it is to be in need, and I know what it is to have plenty. I have learned the secret of being content in any and every situation, whether well fed or hungry, whether living in plenty or in want. I can do all this through him who gives me strength. *-Philippians 4:12-13*
