This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6a5499c14193fd06045bc6c093a746d20e21895d Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Mon Oct 24 14:30:47 2022 +0200 CAMEL-18148: fixed NPE while sending records --- .../camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java b/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java index fe7459f9d09..2e2bbaba3fe 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java @@ -105,7 +105,9 @@ public class SingleNodeKafkaResumeStrategy<T extends Resumable> implements Kafka ProducerRecord<byte[], byte[]> record = new ProducerRecord<>(resumeStrategyConfiguration.getTopic(), key, message); producer.send(record, (recordMetadata, e) -> { - LOG.error("Failed to send message {}", e.getMessage(), e); + if (e != null) { + LOG.error("Failed to send message {}", e.getMessage(), e); + } if (updateCallBack != null) { updateCallBack.onUpdate(e);