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 means providing the âcompeting
consumersâ pattern with whom the messages from topic partitions are spread
across the members of the group.
It seams Spark-Fafka cannot support this for now
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
