Re: Run 1 instance of ExecuteStreamCommand constantly

2017-11-19 Thread Koji Kawamura
Hi, If the script encounters a while(1) loop when it called from NiFi, then NiFi can not do anything until the loop ends. To achieve what you described (keep using the same instance of a script), I'd recommend to implement an API endpoint in that script, e.g. a simple REST endpoint to receive

Re: NiFi 1.3 - PublishKafka_0_10 - A message in the stream exceeds the maximum allowed message size of 1048576 bytes

2017-11-19 Thread Koji Kawamura
Hi Mayank, I've tried to reproduce the issue, but to no avail so far. PublishKafka_0_10 uses the specified Max Request Size as expected and I got the exception if incoming message size exceeds the configured size. And I was able to publish messages whose size is 2.08MB with 10MB Max Request Size.