It does work, at least in the prototype On Tue, Nov 20, 2018 at 2:08 PM Bryan Bende <bbe...@gmail.com> wrote:
> That is correct for the ConsumeKafka processor, but this question was > about the producer side :) > > I believe you can make a producer ahead of time, and then specify the > topic when making a call to actually send a message, at least that > what it looks like the code does in all the PublishKafka variants... > > > https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka.java#L325 > > On Tue, Nov 20, 2018 at 1:53 PM Boris Tyukin <bo...@boristyukin.com> > wrote: > > > > I think they did in on purpose because it takes time (3-5 seconds) for a > consumer group to connect to Kafka (joining consumer group) and whoever > created processor did not want to do it for each flowfile. > > > > On Tue, Nov 20, 2018 at 10:09 AM l vic <lvic4...@gmail.com> wrote: > >> > >> Hi, > >> I have to set topic name property of PutKafka processors from an > attribute of the incoming flowfile...Is there any possible way of doing > this? > >> Thank you, > >> -V >
