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