Re: Convert Simple Kafka Consumer to standalone Spark JavaStream Consumer
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
); } } 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