[2022-06-01 01:14:03,769] ERROR [test_avro_source_v2|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:35)java.lang.NullPointerException  at java.base/java.util.Hashtable.put(Hashtable.java:475)  at org.apache.log4j.MDC.put0(MDC.java:150)  at org.apache.log4j.MDC.put(MDC.java:85)  at org.slf4j.impl.Log4jMDCAdapter.put(Log4jMDCAdapter.java:67)  at org.slf4j.MDC.put(MDC.java:147)  at java.base/java.util.Collections$SingletonMap.forEach(Collections.java:4948)  at io.debezium.util.LoggingContext.forConnector(LoggingContext.java:103)  at io.debezium.connector.common.CdcSourceTaskContext.configureLoggingContext(CdcSourceTaskContext.java:62)  at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:136)  at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)  at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)  at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)  at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)  at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)  at java.base/java.lang.Thread.run(Thread.java:834)[2022-06-01 01:14:04,262] INFO [test_avro_source_v2|task-0] WorkerSourceTask{id=test_avro_source_v2-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:505)[2022-06-01 01:14:04,262] ERROR [test_avro_source_v2|task-0] WorkerSourceTask{id=test_avro_source_v2-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:193)org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.  at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50)  at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:116)  at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)  at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)  at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)  at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)  at java.base/java.lang.Thread.run(Thread.java:834)Caused by: java.lang.NullPointerException  at java.base/java.util.Hashtable.put(Hashtable.java:475)  at org.apache.log4j.MDC.put0(MDC.java:150)  at org.apache.log4j.MDC.put(MDC.java:85)  at org.slf4j.impl.Log4jMDCAdapter.put(Log4jMDCAdapter.java:67)  at org.slf4j.MDC.put(MDC.java:147)  at java.base/java.util.Collections$SingletonMap.forEach(Collections.java:4948)  at io.debezium.util.LoggingContext.forConnector(LoggingContext.java:103)  at io.debezium.connector.common.CdcSourceTaskContext.configureLoggingContext(CdcSourceTaskContext.java:62)  at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:136)  at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)  ... 5 more