# broker-kgo
![Coverage](https://img.shields.io/badge/Coverage-66.1%25-yellow)

TODO:

1) экспортируем текущий оффсет для каждой партиции в группе
2) экспортируем лаг для группы
3) мониторим
   1) если есть лаг больше нуля
   2) если дельта оффсета за нужное нам время не