Here is a non-production example of a file load to Kafka using Scala https://github.com/stealthly/f2k/blob/master/src/main/scala/ly/stealth/f2k/KafkaUploader.scala
If you wanted to convert that to javacode the Scala compiler does that for you :) and makes it importable as jar to your java program, or you can use as reference and rewrite it in Java. /******************************************* Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> ********************************************/ On Sun, Dec 14, 2014 at 1:39 AM, kishore kumar <akishore...@gmail.com> wrote: > > HI Experts, > > I want to load csv files to kafka, anybody help me to write javacode for > this? > > -- > Thanks, > Kishore. >
