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
|