Re: Convert Simple Kafka Consumer to standalone Spark JavaStream Consumer

2015-07-21 Thread Tathagata Das
LConsumer simpleHLConsumer = new > SimpleHLConsumer("localhost:2181", "testgroup", topic); > simpleHLConsumer.testConsumer(); >} > > } > > I want to get my messages through Spark Java Streaming with Kaf

Convert Simple Kafka Consumer to standalone Spark JavaStream Consumer

2015-07-21 Thread Hafsa Asif
); } } I want to get my messages through Spark Java Streaming with Kafka integration. Can anyone help me to reform this code so that I can get same output with Spark Kafka integration. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble