Я видел, как парни использовали или я использовал следующие подходы для отправки журнала приложений в Apache Kafka.
Async Log4J Appender - при условии, что вы используете Log4J для ведения журнала.
Сбор журналов приложений с использованием fluentd
Соединение, написанное на заказ из файла Kafka. Например, здесь .
Я видел, как компании в очень строго регламентированной отрасли пишут изготовители пользовательских журналов с асинхронной и локальной буферизацией для отправки журналов в Kafka. Они пишут собственное решение для форматирования сообщений / шифрования или редактирования некоторой информации, выходящей из их экосистемы.