Ограничение использования памяти потоков Кафки - PullRequest
3 голосов
/ 29 апреля 2019

Есть ли способ ограничить или определить максимальное использование памяти приложением kafka streams?Я включил кэширование в своих хранилищах состояний, но при развертывании в Openshift меня убивают OOM на моих модулях.Я проверил, у меня нет утечек памяти, и все мои итераторы хранилища состояний закрыты.

Я обновил свой RocksDbConfigSetter до рекомендаций, найденных в https://github.com/facebook/rocksdb/wiki/Setup-Options-and-Basic-Tuning#other-general-options, но безуспешно.

Когда я смотрю в каталог хранилища состояний, размер составляет около 2 ГБ.В настоящее время приложению выделено 50 ГБ памяти, и это по-прежнему OOMs

...