[jira] [Closed] (SPARK-18779) Messages being received only from one partition when using Spark Streaming integration for Kafka 0.10 with kafka client library at 0.10.1

2017-01-10 Thread Pranav Nakhe (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pranav Nakhe closed SPARK-18779. Resolution: Not A Bug The issue I had reported is an issue with Kafka 0.10.1.0 client and not with

[jira] [Reopened] (SPARK-18779) Messages being received only from one partition when using Spark Streaming integration for Kafka 0.10 with kafka client library at 0.10.1

2016-12-09 Thread Pranav Nakhe (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pranav Nakhe reopened SPARK-18779: -- Well there seems to be an issue in spark after all. In the ConsumerStrategy class there is a

[jira] [Closed] (SPARK-18779) Messages being received only from one partition when using Spark Streaming integration for Kafka 0.10 with kafka client library at 0.10.1

2016-12-09 Thread Pranav Nakhe (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pranav Nakhe closed SPARK-18779. Resolution: Not A Problem I looked at the code and was able to recreate this issue with a kafka

[jira] [Updated] (SPARK-18779) Messages being received only from one partition when using Spark Streaming integration for Kafka 0.10 with kafka client library at 0.10.1

2016-12-08 Thread Pranav Nakhe (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pranav Nakhe updated SPARK-18779: - Description: I apologize for the earlier descripion which wasnt very clear about the issue. I

[jira] [Created] (SPARK-18779) Upgrade Spark Streaming integration for Kafka 0.10 to use Kafka client library at 0.10.1

2016-12-08 Thread Pranav Nakhe (JIRA)
Pranav Nakhe created SPARK-18779: Summary: Upgrade Spark Streaming integration for Kafka 0.10 to use Kafka client library at 0.10.1 Key: SPARK-18779 URL: https://issues.apache.org/jira/browse/SPARK-18779