Re: Dynamically get schema from element to pass to AvroParquetWriter

2018-01-09 Thread Fabian Hueske
Hi Kyle, I'm not sure I understand the problem. I assume you have one sink for each Avro type (Kafka topic). If you have multiple sinks, why is it not possible to configure each one with the correct Avro schema? Best, Fabian 2018-01-05 22:11 GMT+01:00 Kyle Hamlin : > I implemented an Avro to Pa

Dynamically get schema from element to pass to AvroParquetWriter

2018-01-05 Thread Kyle Hamlin
I implemented an Avro to Parquet writer which previously took an Avro schema in as a string to the constructor and passed it to the AvroParquetWriter. Now I'm wondering if there is a way to get the schema from the element and pass to the AvroParquetWriter. I tried grabbing the schema from the eleme