Системный журнал#

Для логирования Corax использует Apache Log4j2.

Настройка системного журнала#

Уровни логирования и другие параметры логирования настраиваются в файлах:

  • config/log4j.properties — конфигурационный файл для брокера Kafka;

  • config/connect-log4j.properties — конфигурационный файл для Kafka Connect;

  • config/kafka-ui-log4j.properties — конфигурационный файл для графической утилиты Corax UI;

  • config/tools-log4j.properties — конфигурационный файл для cmd line tools;

  • config/zookeeper-log4j.properties — конфигурационный файл для ZooKeeper;

  • config/schemaregistry/schema-registry-log4j.properties — конфигурационный файл для Schema Registry.

Для конфигурирования используйте синтаксис, описанный на официальном сайте Apache Log4j2.

Доступ к системному журналу#

Записи ведутся в лог-файл брокера server.log.

Основные события#

Примеры записей из лог-файла брокера server.log:

Уровень события

Запись

Описание

[ERROR]

[2023-10-05 14:56:23,020] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:254)
at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:108)
at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:2290)
at kafka.zk.KafkaZkClient$.createZkClient(KafkaZkClient.scala:2382)
at kafka.server.KafkaServer.initZkClient(KafkaServer.scala:600)
at kafka.server.KafkaServer.startup(KafkaServer.scala:220)
at ru.sbrf.kafka.distributed.log.DistributedLog$.main(DistributedLog.scala:94)
at ru.sbrf.kafka.distributed.log.DistributedLog.main(DistributedLog.scala)

Критическая ошибка при запуске сервера Kafka: отсутствие подключения брокера к ZooKeeper по истечении тайм-аута

[WARN]

WARN: [2023-12-26 18:40:16,649] WARN [ReplicaFetcher replicaId=1, leaderId=3, fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition test5-9. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist. (kafka.server.ReplicaFetcherThread)

От лидера получен неизвестный ID топика

[INFO]

[2023-12-06 10:28:53,762] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2023-12-06 10:28:53,768] INFO Kafka 3.4.0 starting... (ru.sbrf.kafka.distributed.log.DistributedLog$)

Регистрация и запуск брокера Kafka

[DEBUG]

[2023-12-11 12:04:16,383] DEBUG [GroupCoordinator 1]: Member id consumer-UiAclConsumer-1-81ef9138-6224-4413-a841-0d46c8b87f70 was not found in UiAclConsumer during heartbeat completion check (kafka.coordinator.group.GroupCoordinator)

Идентификатор члена consumer-группы не найден во время проверки heartbeat («сердцебиения»)

[TRACE]

[2024-01-31 12:50:28,298] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)

Сообщение о начале проверки необходимости запуска автоматической балансировки лидеров

Внимание!

Включение уровней логирования TRACE и DEBUG не рекомендуется в промышленном использовании.