@Andrew Lim 1)My requirement is We have CSV data in one of the remote machine. every one hour csv data(huge data) is generating in remote machine. So i used SFTP for that. From there i need to put data to Kafka topics.So i used Publish Kafka record.I have not used Json conversion which is written in above article.But i am going to use it. 2) Yes i got the flow from your article. I have missed schema.name attribute and schema registry bcoz i dont understand what to mention in this.do i need to mention column name which is there in input file. 3) and I am just started learning kafka. and i created partitions in one of topic, i have no idea how to load data to specific partitions using nifi. If you have any suggestion better than this can you guide me ? ... View more

@Andrew Lim:a Can you help on this ? ... View more

@Andrew Lim I am sharing the settings. kindly checkstep-1.pnggetsftp-settings.pngpublishkafka.pngcsvreadersettings.pngcsv-writer-settings.png ... View more

and i got below error. screenshot-from-2018-03-07-10-41-56.png ... View more

@Andrew Lim instead of zookeeper we can mention bootstrap-server rite? Here your giving example of data from website. But i have import the data from remote machine (linux) and i have used GetSFTP is dat right option ? anything better than this please suggest. ... View more

@Andrew Lim Hi Thanks for sharing this post. can you please help to give query to to check wheather incoming data from nifi to kafka ? how can we verify it in kafka ? And also i am using GetSFTP to get the CSV data from remote machine. ... View more