Skip to content

Commit ad09778

Browse files
garyrussellartembilan
authored andcommitted
Fix NPE when Jackson not present
When using the `KafkaTemplate.send(Message<?>)` variant, an NPE was thrown if Jackson wasn't on the classpath. # Conflicts: # spring-kafka/src/main/java/org/springframework/kafka/support/converter/MessagingMessageConverter.java * Also revert to `1.3.2.B-S`
1 parent 56aa38f commit ad09778

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

gradle.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
1-
version=1.3.3.BUILD-SNAPSHOT
1+
version=1.3.2.BUILD-SNAPSHOT
22
org.gradle.daemon=true

spring-kafka/src/main/java/org/springframework/kafka/support/converter/MessagingMessageConverter.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,9 @@ public Message<?> toMessage(ConsumerRecord<?, ?> record, Acknowledgment acknowle
132132
Object payload = convertPayload(message);
133133
Long timestamp = headers.get(KafkaHeaders.TIMESTAMP, Long.class);
134134
RecordHeaders recordHeaders = new RecordHeaders();
135-
this.headerMapper.fromHeaders(headers, recordHeaders);
135+
if (this.headerMapper != null) {
136+
this.headerMapper.fromHeaders(headers, recordHeaders);
137+
}
136138
return new ProducerRecord(topic == null ? defaultTopic : topic, partition, timestamp, key, payload,
137139
recordHeaders);
138140
}

0 commit comments

Comments
 (0)