Экспорт/стримминг логов кафки в ELK на клиентской стороне

Бывают случаи когда видно, что есть ошибки при записи/чтении в кафку, но хотелось бы иметь возможность иметь логи кафки на своей стороне в своей ELK (или любой другой популярной системе) и возможность почитать их, настроить алерты по логам и тп