GH-STREAM-2971 Properly handle Kafka tombstone payload conversion

This commit is contained in:
Oleg Zhurakousky
2024-07-17 16:09:53 +02:00
parent 76d92789d1
commit da91630320

View File

@@ -128,6 +128,9 @@ public class JsonMessageConverter extends AbstractMessageConverter {
@Override
protected Object convertToInternal(Object payload, @Nullable MessageHeaders headers,
@Nullable Object conversionHint) {
if (payload.getClass().getName().equals("org.springframework.kafka.support.KafkaNull")) {
return payload;
}
return jsonMapper.toJson(payload);
}