Я должен проанализировать журналы сервера двух разных приложений. Журналы будут генерироваться непрерывно 24 * 7. У меня есть учетные данные сервера, на котором создаются журналы. Мне нужно получить эти данные журналов в kafka и извлечь некоторую информацию об ошибках из этих журналов, используя python (применяя регулярное выражение), и подготовить панель мониторинга в реальном времени с данными, которые я извлек. Как я могу проглотить те данные журнала, которые непрерывно генерируются в kafka? Нужно ли использовать NiFi? Я новичок в этом сценарии, поэтому, если вы поняли мое требование, приведенное выше, расскажите, как мне этого добиться. Спасибо.