<html><head></head><body><div style="font-family: Verdana;font-size:
12.0px;"><div>
<div>Matt,</div>
<div> </div>
<div>got it resolved with the help of Mark.</div>
<div> </div>
<div>One more question: do you have a link to the "Variable Registry"
you mentioned?</div>
<div> </div>
<div>Rgds,</div>
<div> </div>
<div>Uwe</div>
<div>
<div name="quote" style="margin:10px 5px 5px 10px; padding: 10px 0 10px 10px; border-left:2px
solid #C3D9E5; word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-line-break: after-white-space;">
<div style="margin:0 0 10px 0;"><b>Gesendet:</b> Donnerstag, 22.
Juni 2017 um 21:47 Uhr<br/>
<b>Von:</b> "Matt Burgess" <mattyb149@apache.org><br/>
<b>An:</b> users@nifi.apache.org<br/>
<b>Betreff:</b> Re: Nifi 1.3.0 - Problem with schema.name and ConsumeKafkaRecord_0_10
processor</div>
<div name="quoted-content">Uwe,<br/>
<br/>
Since ConsumeKafkaRecord is a "source" processor, you won't be able
to<br/>
set schema.name as a FlowFile attribute. However you could set it as a<br/>
property in a Variable Registry file and use that. Are your schemas<br/>
dynamic based on the topic? If not, you likely don't need to use the<br/>
schema.name attribute, you could hard-code the name in the reader<br/>
(${schema.name} is just the default), or even the schema itself (if<br/>
you use the Schema Text strategy and Schema Text set to your schema).<br/>
<br/>
If the schemas depend on the topic, I'm not sure a single<br/>
ConsumeKafkaRecord would work in this case. Having said that, it might<br/>
be cool as an improvement to make a "transient attribute" available,<br/>
exposing "topic.name" as what might look like a flow file attribute to<br/>
the EL evaluator, and whose value would be the topic name for the<br/>
current incoming message.<br/>
<br/>
Regards,<br/>
Matt<br/>
<br/>
<br/>
On Thu, Jun 22, 2017 at 3:40 PM, Uwe Geercken <uwe.geercken@web.de> wrote:<br/>
> Hello,<br/>
><br/>
> besides my other problem with the ConsumeKafkaRecord_0_10 processor, I have another
question.<br/>
><br/>
> 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}.<br/>
><br/>
> 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.<br/>
><br/>
> Thanks for any comments or help.<br/>
><br/>
> Rgds,<br/>
><br/>
> Uwe</div>
</div>
</div>
</div></div></body></html>
|