Hi Guys,I figured out the problem.
It seems PublishKafka treated the flowfile from GetFile as a single record 
because I did not set Message Demarcator.
I set that to "\n" (thought that was the right way since the doc says it 
supports Expression Language), but then it should be enter as "Ctrl-Enter" or 
"Shift-Enter" (for me, it's "Shift-Enter") as per the doc.
Thanks anyway.

Rgds.Daniel Yeap

      From: Daniel Yeap <[email protected]>
 To: "[email protected]" <[email protected]> 
 Sent: Saturday, July 22, 2017 12:17 PM
 Subject: PublishKafka_0_10 Indefinite Stuck State
   
Hi,I am new to Nifi, so please forgive me if I am asking dumb question :)
I setup a GetFile to PublishKafka_0_10 flow.
If I create a simple source file with some small content, the flow works fine.
My intention is to load a file which is about 190MB.
If I put that file in, GetFile will read it fine and push it to the queue.
However, PublishKafka will not read anything from the queue and there isn't any 
message in the nifi-app.log even if I set the "Bulletin Level" of PublishKafka 
to DEBUG.
Any clue what could be happening or how to troubleshoot further?
Thanks.
Rgds,Daniel Yeap

   

Reply via email to