Github user jerryshao commented on the issue:
https://github.com/apache/spark/pull/19274
Yes, I understand your scenario, but my concern is that your proposal is
quite scenario specific, it may well serve your scenario, but somehow it breaks
the design purpose of KafkaRDD. From my understanding lots of user use
`repartition` or `coalease` to increase the parallelism, so somehow your
problem can be solved by this.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
