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,
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 consumer's position via KafkaCons
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
wrote:
> Hello Team,
>
> I s
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
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
Exce
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 to create a topic in th
