Re: NiFi JSON enrichment

2018-12-27 Thread Austin Heyne
James, A little late to the show but hopefully this is useful. What we typically do for data enrichment is we'll use an EvaluateJsonPath processor to pull JSON fields out into attributes under a common key, e.g. foo.model. We then have a PutRedis processor that grabs everything under foo and

Re: ConsumeKafka demarcator

2018-12-27 Thread Boris Tyukin
I've looked into source code and I see that I do not have to use a single character but can use any string which then is encoded as a byte array by NiFi. I can generate UUID and use it as a safe demarcator. On Wed, Dec 26, 2018 at 4:47 PM Boris Tyukin wrote: > Hello, > > I would like to batch Ka