GH-3779: Fix KafkaTemplate from hiding error when starting observation

Fixes: #3779

This fixes that exceptions thrown from `observation.start()` are hidden by `KafkaTemplate` throwing a new exception due to registering observation error without successfully starting the observation.

Signed-off-by: Christian Fredriksson <christian.fredriksson.2@volvocars.com>

(cherry picked from commit bdd1fd3556)
This commit is contained in:
Christian Fredriksson
2025-03-05 15:06:43 +01:00
committed by Spring Builds
parent 855d294dab
commit 5726123f94

View File

@@ -799,8 +799,8 @@ public class KafkaTemplate<K, V> implements KafkaOperations<K, V>, ApplicationCo
this.observationConvention, DefaultKafkaTemplateObservationConvention.INSTANCE,
() -> new KafkaRecordSenderContext(producerRecord, this.beanName, this::clusterId),
this.observationRegistry);
observation.start();
try {
observation.start();
try (Observation.Scope ignored = observation.openScope()) {
return doSend(producerRecord, observation);
}