Apenas para esclarecer algumas coisas: estou falando sobre o arquivo de log do processo que contém as mensagens stdout e stderr.
Este é o meu arquivo de unidade do sistema:
[Unit]
Description=Apache Kafka server
Documentation=http://kafka.apache.org
Requires=network.target remote-fs.target
After=network.target remote-fs.target
[Service]
Type=simple
PIDFile=/var/run/kafka.pid
User=kafka
Group=kafka
Environment="JAVA_HOME=/usr/lib/jvm/jre"
Environment="KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:/var/log/kafka"
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
Restart=on-failure
SyslogIdentifier=kafka
[Install]
WantedBy=multi-user.target
Observe que adicionei a variável de ambiente KAFKA_LOG4J_OPTS.
No entanto, isso não parece fazer nada. Esta é a saída, quando tento iniciar meu serviço:
Feb 11 00:55:30 kafka01 kafka[4047]: mkdir: cannot create directory ‘/opt/kafka/bin/../logs’: Permission denied
Feb 11 00:55:30 kafka01 kafka[4047]: OpenJDK 64-Bit Server VM warning: Cannot open file /opt/kafka/bin/../logs/kafkaServer-gc.log due to No such file or directory
Feb 11 00:55:30 kafka01 kafka[4047]: log4j:WARN No appenders could be found for logger (kafka.Kafka$).
Feb 11 00:55:30 kafka01 kafka[4047]: log4j:WARN Please initialize the log4j system properly.
Então, alguém pode me dizer a maneira correta de alterar a localização do arquivo de log kafka? KAFKA_LOG4J_OPTS não funciona, KAFKA_LOG_DIR também não funciona (= Eu esperava que o kafka implementasse isso semelhante ao zookeeper). A documentação do kafka também não me diz.
Para outros caras desafortunados como o meu, você precisa modificar a variável de ambiente LOG_DIR (testado para o Kafka v0.11 ).
Se você abrir o script kafka-server-start ou /usr/bin/zookeeper-server-start , verá na parte inferior que ele chama kafka-run-class script. E você verá que usa LOG_DIR como a pasta para os logs do serviço (não confundir com os dados dos tópicos do kafka).
Tags kafka