Hello,
 
besides my other problem with the ConsumeKafkaRecord_0_10 processor, I have 
another question.
 
Using the AvroSchemaRegistry 1.3.0, I can define a schema and reference it e.g. 
in the CSVReader controller using the 'Schema Name' property and by setting 
this property to ${schema.name}.

But how can I set this attribute ${schema.name}? Usually I would do so using 
the UpdateAttribute Processor but the ConsumeKafkaRecord_0_10 processor is the 
first one in the flow and it does not allow incomming connections.

Thanks for any comments or help.

Rgds,

Uwe

Reply via email to