0f24c6f8ab
We have hundreds of kafka topics need to be consumed in one application. The application master will throw OOM exception after hanging for nearly half of an hour. OOM happens in the env with a lot of topics, and it's not convenient to set up such kind of env in the unit test. So I didn't change/add test case. Author: Yuanbo Liu <yuanbo@Yuanbos-MacBook-Air.local> Author: yuanbo <yuanbo@apache.org> Closes #21690 from yuanboliu/master. |
||
---|---|---|
.. | ||
src | ||
pom.xml |