nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Uwe Geercken" <uwe.geerc...@web.de>
Subject Aw: Re: Nifi 1.3.0 - Problem with schema.name and ConsumeKafkaRecord_0_10 processor
Date Thu, 22 Jun 2017 20:45:42 GMT
<html><head></head><body><div style="font-family: Verdana;font-size:
12.0px;"><div>
<div>Matt,</div>

<div>&nbsp;</div>

<div>got it resolved with the help of Mark.</div>

<div>&nbsp;</div>

<div>One more question: do you have a link to the &quot;Variable Registry&quot;
you mentioned?</div>

<div>&nbsp;</div>

<div>Rgds,</div>

<div>&nbsp;</div>

<div>Uwe</div>

<div>&nbsp;
<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>&nbsp;Donnerstag, 22.
Juni 2017 um 21:47 Uhr<br/>
<b>Von:</b>&nbsp;&quot;Matt Burgess&quot; &lt;mattyb149@apache.org&gt;<br/>
<b>An:</b>&nbsp;users@nifi.apache.org<br/>
<b>Betreff:</b>&nbsp;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 &quot;source&quot; processor, you won&#39;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&#39;t need to use the<br/>
schema.name attribute, you could hard-code the name in the reader<br/>
(&#36;{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&#39;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 &quot;transient attribute&quot; available,<br/>
exposing &quot;topic.name&quot; 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 &lt;uwe.geercken@web.de&gt; wrote:<br/>
&gt; Hello,<br/>
&gt;<br/>
&gt; besides my other problem with the ConsumeKafkaRecord_0_10 processor, I have another
question.<br/>
&gt;<br/>
&gt; Using the AvroSchemaRegistry 1.3.0, I can define a schema and reference it e.g. in
the CSVReader controller using the &#39;Schema Name&#39; property and by setting this
property to &#36;{schema.name}.<br/>
&gt;<br/>
&gt; But how can I set this attribute &#36;{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/>
&gt;<br/>
&gt; Thanks for any comments or help.<br/>
&gt;<br/>
&gt; Rgds,<br/>
&gt;<br/>
&gt; Uwe</div>
</div>
</div>
</div></div></body></html>

Mime
View raw message