我正在使用kafka rest代理启动confluent连接器，但在读取connect.stdout文件中写入的所有日志时出现错误
我需要每个连接器在一个单独的日志文件日志。
像jdbc-testtable-source.log、cassandra-dump-sink.log这样我就可以把它发送给最终用户
我已经尝试使用grep命令将日志从connect.stdout文件和log4j文件中分离出来进行日志记录
我正在使用kafka rest代理启动confluent连接器，但在读取connect.stdout文件中写入的所有日志时出现错误
我需要每个连接器在一个单独的日志文件日志。
像jdbc-testtable-source.log、cassandra-dump-sink.log这样我就可以把它发送给最终用户
我已经尝试使用grep命令将日志从connect.stdout文件和log4j文件中分离出来进行日志记录
1条答案
按热度按时间ha5z0ras1#
在ApacheKafka2.2中，一个工作进程将所有内容都记录到一个日志文件中，而不指示每个条目来自哪个连接器。
kip-449将添加到apachekafka2.3中，这将使识别哪个日志条目来自哪个连接器变得更加容易。