##Дано:
Директория, в которой лежат файлы по следующей структуре: <topic-name>/history/<run-timestamp>/offsets.csv
<topic-name> - имя топика (по сути просто строка)
<run-timestamp> - таймстемп запуска некоей процедуры, в формате YYYY-MM-DD-HH-mm-ss (минуты и секунды с лидирующими нулями)
offsets.csv - файл с двумя колонками, разделенными запятыми.
Первая колонка - номер партиции (int), вторая колонка - число сообщений (long). В одном файле десятки записей.
##Как запустить
Скачавший этот .jar и запустивший его с одним аргументом - путём к директории, описанной выше, обнаружит на http://localhost:8080/ страницу, на которой доступны ссылки на статистику и списку партиций по последнему таймстепу каждого топика - это
http://localhost:8080/topic/stat?name=_\<topic-name>_ и http://localhost:8080/topic/list?name=_\<topic-name>_ соответственно.
##Кэширование
Я подразумеваю, что попавший в эту систему папок файл не будет изменяться и не пропадёт.
Для тех, кто хочет менять файлы или удалять их находу и не удивляться, что сервис этого не замечает, подойдёт этот .jar
-
Notifications
You must be signed in to change notification settings - Fork 0
shtykh/TopicViewer
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|