我要去汇合医院 kafka-avro-console-consumer
如快速入门教程中所述:
kafka-avro-console-consumer --topic test --zookeeper localhost:2181 --from-beginning
但是,我创建了一个单独的用户 kafka
运行此命令。我收到了错误信息
mkdir: cannot create directory '/usr/bin/../logs': Permission denied
log4j:ERROR setFile(null,true) call failed.
java.io.FileNotFoundException: /usr/bin/../logs/schema-registry.log (No such file or directory)
[...]
我宁愿不给你钱 kafka
对整个 /usr/bin
目录。Kafka到底想在哪里创造这个世界 logs
目录?
1条答案
按热度按时间rqenqsqc1#
这个
kafka-avro-console-consumer
尊重LOG_DIR
因此,如果您设置它,日志文件将改为写入此目录。