从同一个Kafka服务，可以读取消息，但写入消息报错： AsyncSinkOperator write Record error
请问是什么问题？
java.lang.NullPointerException: null
at com.fr.dp.integration.util.PipelineEventRecordUtils.getBeforeAndAfterKeys(PipelineEventRecordUtils.java:24) ~[fdl-datasource-4.2.jar:?]
at com.fr.dp.integration.core.taskgroup.writer.RealTimeConsumer.recordFailed(RealTimeConsumer.java:376) ~[fdl-datasource-4.2.jar:?]
at com.fr.dp.datasource.ri.writer.KafkaRealTimeConsumer.lambda$null$0(KafkaRealTimeConsumer.java:94) ~[fdl-datasource-4.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:1108) ~[fdl-third-4.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:993) ~[fdl-third-4.2.jar:?]
at com.fr.dp.integration.core.kafka.DPKafkaProducer.send(DPKafkaProducer.java:58) ~[fdl-datasource-4.2.jar:?]
1 评论
从同一个Kafka服务，可以读取消息，但写入消息报错： AsyncSinkOperator write Record error
请问是什么问题？
java.lang.NullPointerException: null
at com.fr.dp.integration.util.PipelineEventRecordUtils.getBeforeAndAfterKeys(PipelineEventRecordUtils.java:24) ~[fdl-datasource-4.2.jar:?]
at com.fr.dp.integration.core.taskgroup.writer.RealTimeConsumer.recordFailed(RealTimeConsumer.java:376) ~[fdl-datasource-4.2.jar:?]
at com.fr.dp.datasource.ri.writer.KafkaRealTimeConsumer.lambda$null$0(KafkaRealTimeConsumer.java:94) ~[fdl-datasource-4.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:1108) ~[fdl-third-4.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:993) ~[fdl-third-4.2.jar:?]
at com.fr.dp.integration.core.kafka.DPKafkaProducer.send(DPKafkaProducer.java:58) ~[fdl-datasource-4.2.jar:?]
赞 0 2025-03-20 15:50