Github user koeninger commented on the issue:
https://github.com/apache/spark/pull/20767
Can you clarify why you want to allow only 1 cached consumer per
topicpartition, closing any others at task end?
It seems like opening and closing consumers would be less efficient than
allowing a pool of more than one consumer per topicpartition.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
