Re: KafkaUtils.createStream(..) is removed for API

createStream() is still in external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala But it is not in external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaUtils.scala FYI On Sun, Feb 18, 2018 at 5:17 PM, naresh Goud

Re: Java Consumer Not reading message -

Thanks Matthias for replying. The answer has been discussed the stackoverflow link which I have posted in the question. On 16-Feb-2018 11:35 PM, "Matthias J. Sax" wrote: Can you check the committed offsets using bin/kafka-consumer-group.sh ? Also inspect your

ey.converter: Class io.confluent.connect.avro.AvroConverter could not be found

Hello all, I have one kafka and a one schema-registry running on my home, but when I launched this command: I get the following stack: kafka_2.11-1.0.0/bin$ ./connect-standalone.sh /home/adryen/git/schema-registry/config/connect-avro-standalone.properties ../config/mysql-connect.properties

KafkaUtils.createStream(..) is removed for API

Hello Team, I see "KafkaUtils.createStream() " method not available in spark 2.2.1. Can someone please confirm if these methods are removed? below is my pom.xml entries. 2.11.8 2.11 org.apache.spark spark-streaming_${scala.tools.version} 2.2.1 provided

Re: KafkaUtils.createStream(..) is removed for API

Thanks Ted. I see createDirectStream is experimental as annotated with "org.apache.spark.annotation.Experimental". Is it possible to be this API will be removed in future? because we wanted to use this API in one of our production jobs. afraid if it will not be supported in future. Thank you,

Re: Zookeeper Error

Hi, in your message there is "locahost", but I am pretty sure you wanted to use "localhost", including the "l", right? This one will usually be resolvable, hence doesn't throw an unknownHostException Regards Maria Pilar schrieb am So., 18. Feb. 2018, 02:49: > When i try