我使用的是confluent Kafka jdbc connector(https://github.com/confluentinc/kafka-connect-jdbc),但是没有找到https://docs.confluent.io/platform/current/connect/logging.html上描述的**/etc/Kafka/connect-log4j.properties**文件,我想知道这个connector输出如何通过log4j记录日志。
我认为日志配置文件(log4j.properties)应该放在src/main/resources目录下,但我只在src/test/resources目录下找到了日志文件。为什么这个路径下的文件会生效,或者Kafka conenct有什么默认配置?
下面是pom.xml中log4j的配置:
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<scope>test</scope>
</dependency>
字符串
1条答案
按热度按时间xjreopfe1#
对于特定的连接器插件来说,连接器不是唯一的。
当运行
connect-disributed.sh
文件时,它包含对整个worker使用的log4j.properties文件的引用。src/main/resources
是Kafka源代码的一部分。你不应该从源代码运行Connectors。JDBC Connector应该添加到connect-distributed.properties > plugin.path
设置中.然后你使用connect-distributed.sh
运行服务器,这是输出日志的地方。