Конфигурирование аудита событий над брокером в лог-файл#

  1. Для включения аудита над брокером Corax в лог-файл, добавьте в конфигурационный файл KAFKA_DIR/config/server.properties строки:

    kafka.se.audit.enable=true
    kafka.se.audit.provider=kafka.audit.provider.LogAuditProvider
    

    где kafka.se.audit.enable — глобальное включение аудита;

    Примечание

    По умолчанию будет включен аудит записи действий на брокере в лог-файл kafka-audit.log на уровне INFO.

  2. При необходимости указать другой лог-файл для аудита и/или задать свои параметры (уровень логирования, вид записи, форматирование или режим записи rolling update), укажите appender в файле config/log4j.properties:

    log4j.appender.auditFileAppender = org.apache.log4j.RollingFileAppender //включение режима записи rolling update
    log4j.appender.auditFileAppender.File = ${kafka.logs.dir}/kafka-audit.log //путь к лог-файлу
    log4j.appender.auditFileAppender.layout.ConversionPattern = [%d] %p %m (%c)%n //формат даты и времени
    log4j.logger.kafka.audit.provider.LogAuditProvider = INFO, auditFileAppender //уровень логирования