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 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 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 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 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 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 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 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 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 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 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
11 matches
Mail list logo