我正在使用 Kafka rest 代理启动融合连接器,但在读取日志中的错误时遇到问题 连接.stdout 文件中
写入的所有日志我需要在单独的日志文件中为每个连接器提供日志。
像JDBC-testTable-source.log,Cassandra-dump-sink.log所以我可以把它发送给最终用户
我尝试使用 grep 命令将日志与 connect.stdout 文件分开和用于日志记录的 log4j 文件
从 Apache Kafka 2.2 开始,工作线程将所有内容记录到单个日志文件中,每个条目都没有指示它来自哪个连接器。
KIP-449 将添加到 Apache Kafka 2.3 中,这将使识别哪个日志条目来自哪个连接器变得更加容易。