apache-kafka - Log4j 无法正常工作
问题描述
如何让 kafka 流与 log4j 一起工作?例如,执行以下操作不会在控制台中产生任何输出
public class Streamtest{
final static Logger logger = Logger.getLogger(Streamtest.class.getName());
public static void main(String[] args) {
logger.debug("In main");
Log4j 属性
log4j.rootLogger=DEBUG,stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=[%d] %p [%t] %m (%c)%n
运行命令
java -cp /tmp/Streamtest.jar:/usr/hdp/2.6.1.0-129/kafka/libs/* -Djava.security.auth.login.config=/tmp/kafka_jaas.conf org.cox.test.Streamtest -Dlog4j.configuration=file:/tmp/log4j.properties
更正的命令
java -cp /tmp/Streamtest.jar:/usr/hdp/2.6.1.0-129/kafka/libs/* -Djava.security.auth.login.config=/tmp/kafka_jaas.conf -Dlog4j.configuration=file:/tmp/log4j.properties org.cox.test.Streamtest
解决方案
想通了,见上面更正的命令。属性参数应首先保留,然后是主类。愚蠢的错误!
推荐阅读
- python - 如何使用 ./ 从 Linux 终端运行 python?
- python - 全局变量不会在外部进程的循环中更新
- image-processing - 在特定字体上训练 Tesseract 会产生空的 tr 文件
- javascript - 为什么我的 socket.io 事件无法在我的承诺链范围内或在函数范围内触发?
- sabre - 如何为旅客添加特殊服务?
- tensorflow - keras 约束没有被调用
- angular - 添加ngrx是否总是证明自己(在角度项目中)
- azure - 连接到 Azure AD 条件访问 VPN 命令行
- connection-string - 如何使用 Sybase SQLAnywhere.SAConnection 进行远程连接?
- css - 仅当孩子有特定的类时才用于直接孩子的 CSS 选择器