[
https://issues.apache.org/jira/browse/SPARK-6594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14385743#comment-14385743
]
Sean Owen commented on SPARK-6594:
----------------------------------
There's no useful detail here. Can you elaborate what exactly you are running,
what you observe? what is the input, what are the states of the topics, what
information leads you to believe streaming is not reading?
It's certainly not true that they don't work in general. I am successfully
using this exact combination now and have had no problems.
> Spark Streaming can't receive data from kafka
> ---------------------------------------------
>
> Key: SPARK-6594
> URL: https://issues.apache.org/jira/browse/SPARK-6594
> Project: Spark
> Issue Type: Bug
> Affects Versions: 1.2.1
> Environment: kafka_2.10-0.8.1.1 + Spark-1.2.1
> Reporter: q79969786
>
> I use KafkaUtils to receive data from Kafka In my Spark streaming application
> as follows:
> Map<String, Integer> topicorder = new HashMap<String, Integer>();
> topicorder.put("order", Integer.valueOf(readThread));
> JavaPairReceiverInputDStream<String, String> jPRIDSOrder =
> KafkaUtils.createStream(jssc, zkQuorum, group, topicorder);
> It worked well at fist, but after I submit this application several times,
> Spark streaming can‘t receive data anymore(Kafka works well).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
