[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user koeninger commented on the issue: https://github.com/apache/spark/pull/21038 @SehanRathnayake Kafka is designed for at most one consumer per partition per consumer group at any given point in time, https://kafka.apache.org/documentation/#design_consumerposition

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user SehanRathnayake commented on the issue: https://github.com/apache/spark/pull/21038 I think "This is fundamentally not correct, different apps should use different consumer group" statement is wrong. .According to Kafka Having consumers as part of the same consumer group

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user jerryshao commented on the issue: https://github.com/apache/spark/pull/21038 Thanks @koeninger for the review. --- - To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands,

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user koeninger commented on the issue: https://github.com/apache/spark/pull/21038 Seems like that should help address the confusion. Merging to master. --- - To unsubscribe, e-mail:

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user jerryshao commented on the issue: https://github.com/apache/spark/pull/21038 Ping @koeninger , would you please help to review again. Thanks! --- - To unsubscribe, e-mail:

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user AmplabJenkins commented on the issue: https://github.com/apache/spark/pull/21038 Merged build finished. Test PASSed. --- - To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user AmplabJenkins commented on the issue: https://github.com/apache/spark/pull/21038 Test PASSed. Refer to this link for build results (access rights to CI server needed): https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/89230/ Test PASSed. ---

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user SparkQA commented on the issue: https://github.com/apache/spark/pull/21038 **[Test build #89230 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/89230/testReport)** for PR 21038 at commit

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user AmplabJenkins commented on the issue: https://github.com/apache/spark/pull/21038 Test PASSed. Refer to this link for build results (access rights to CI server needed): https://amplab.cs.berkeley.edu/jenkins//job/testing-k8s-prb-make-spark-distribution/2234/

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user AmplabJenkins commented on the issue: https://github.com/apache/spark/pull/21038 Merged build finished. Test PASSed. --- - To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional

[GitHub] spark issue #21038: [SPARK-22968][DStream] Throw an exception on partition r...

Github user SparkQA commented on the issue: https://github.com/apache/spark/pull/21038 **[Test build #89230 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/89230/testReport)** for PR 21038 at commit