alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5180 Put the MysqlPartition values to MDC getting NPE in logging context phase

Browse Source
This commit is contained in:
harveyyue 2022-06-01 11:17:27 +08:00 committed by Jiri Pechanec
parent 7ac91c4450
commit 9a3afac243
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
debezium-core/src/main/java/io/debezium/util/LoggingContext.java
View File

@ -99,8 +99,12 @@ public static PreviousContext forConnector(String connectorType, String connecto
if (taskId != null) { if (taskId != null) {
MDC.put(TASK_ID, taskId); MDC.put(TASK_ID, taskId);
} }
if (partition != null) { if (partition != null && partition.getLoggingContext() != null) {
partition.getLoggingContext().forEach(MDC::put); partition.getLoggingContext().forEach((k, v) -> {
if (k != null && v != null) {
MDC.put(k, v);
}
});
} }
MDC.put(CONNECTOR_TYPE, connectorType); MDC.put(CONNECTOR_TYPE, connectorType);
MDC.put(CONNECTOR_NAME, connectorName); MDC.put(CONNECTOR_NAME, connectorName);