Flume перехватчик для метки времени сообщения kafka?

Я ищу специальный перехватчик потока, извлекающий временную метку сообщений из источника Кафки.

Я счастлив попытаться написать это сам, но это кажется достаточно распространенной идеей - я думаю, что кто-то другой, возможно, уже сделал это? Я просто не могу найти какие-либо ресурсы или проекты в Интернете.

Был бы признателен за любые указатели или ссылки!