5.3. 配置 Debezium 日志记录

流程

1. 打开 connect-log4j.properties 文件。

2. 为连接器配置日志记录器。

   以下示例为 MySQL 连接器和连接器使用的数据库模式历史记录实施配置日志记录器，并将它们设置为 log DEBUG 级别信息：
   

   例 5.2. connect-log4j.properties 配置来启用日志记录器，并将日志级别设置为 DEBUG

   ...
   log4j.logger.io.debezium.connector.mysql=DEBUG, stdout  1
   log4j.logger.io.debezium.relational.history=DEBUG, stdout  2
   
   log4j.additivity.io.debezium.connector.mysql=false  3
   log4j.additivity.io.debezium.storage.kafka.history=false
   ...

   表 5.2. 启用日志记录器并设置日志级别的 connect-log4j.properties 设置的描述

   属性	描述
   1	配置名为 io.debezium.connector.mysql 的日志记录器，以将 DEBUG、INFO、WARN 和 ERROR 消息发送到 stdout 附加器。
   2	配置名为 io.debezium.relational.history 的日志记录器，以将 DEBUG、INFO、WARN 和 ERROR 消息发送到 stdout 附加器。
   3	此 log4j. additivity.io 条目对禁用添加性。如果您使用多个附加器，请将 additivity 值设置为 false，以防止将重复的日志消息发送到父日志记录器的附加者中。

3. 如有必要，更改连接器中类的特定子集的日志记录级别。

   增加整个连接器的日志级别会增加日志详细程度，这可能会造成难以了解发生的情况。在这些情况下，您只能为与您要故障排除的问题相关的类子集更改日志级别。

   1. 将连接器的日志级别设置为 DEBUG 或 TRACE。

   2. 查看连接器的日志消息。

      查找与您要故障排除相关的问题相关的日志消息。每个日志消息的末尾显示生成消息的 Java 类的名称。

   3. 将连接器的日志记录级别重新设置为 INFO。

   4. 为您确定的每个 Java 类配置日志记录器。

      例如，如果您不确定为什么 MySQL 连接器在处理 binlog 时跳过一些事件的情况。您可以把连接器的日志级别保持在 INFO 状态，然后仅对读取 binlog 的类配置 DEBUG 或 TRACE，而不是为整个连接器打开 DEBUG 或 TRACE 日志：

      例 5.3. connect-log4j.properties 配置，为 BinlogReader 类启用 DEBUG 日志记录

      ...
      log4j.logger.io.debezium.connector.mysql=INFO, stdout
      log4j.logger.io.debezium.connector.mysql.BinlogReader=DEBUG, stdout
      log4j.logger.io.debezium.relational.history=INFO, stdout
      
      log4j.additivity.io.debezium.connector.mysql=false
      log4j.additivity.io.debezium.storage.kafka.history=false
      log4j.additivity.io.debezium.connector.mysql.BinlogReader=false
      ...

流程

1. 打开 connect-log4j.properties 文件。

2. 配置附加器以使用任何受支持的 Debezium MDC 属性。在以下示例中，stdout appender 被配置为使用这些 MDC 属性。

   例 5.4. connect-log4j.properties 配置将 stdout 附加程序设置为使用 MDC 属性

   ...
   log4j.appender.stdout.layout.ConversionPattern=%d{ISO8601} %-5p  %X{dbz.connectorType}|%X{dbz.connectorName}|%X{dbz.connectorContext}  %m   [%c]%n
   ...

   上例中的配置生成类似以下输出中的日志消息：

   ...
   2017-02-07 20:49:37,692 INFO   MySQL|dbserver1|snapshot  Starting snapshot for jdbc:mysql://mysql:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=convertToNull with user 'debezium'   [io.debezium.connector.mysql.SnapshotReader]
   2017-02-07 20:49:37,696 INFO   MySQL|dbserver1|snapshot  Snapshot is using user 'debezium' with these MySQL grants:   [io.debezium.connector.mysql.SnapshotReader]
   2017-02-07 20:49:37,697 INFO   MySQL|dbserver1|snapshot  GRANT SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'debezium'@'%'   [io.debezium.connector.mysql.SnapshotReader]
   ...