PR review

Author: sobychacko

spring-kafka/src/main/java/org/springframework/kafka/support/micrometer/KafkaRecordSenderContext.java

@@ -21,7 +21,6 @@
 
 import io.micrometer.observation.transport.SenderContext;
 import org.apache.kafka.clients.producer.ProducerRecord;
-import org.apache.kafka.common.header.Header;
 import org.apache.kafka.common.header.Headers;
 
 /**
@@ -44,10 +43,7 @@ public class KafkaRecordSenderContext extends SenderContext<ProducerRecord<?, ?>
 	public KafkaRecordSenderContext(ProducerRecord<?, ?> record, String beanName, Supplier<String> clusterId) {
 		super((carrier, key, value) -> {
 			Headers headers = record.headers();
-			Iterable<Header> existingHeaders = headers.headers(key);
-			if (existingHeaders.iterator().hasNext()) {
-				headers.remove(key);
-			}
+			headers.remove(key);
 			headers.add(key, value == null ? null : value.getBytes(StandardCharsets.UTF_8));
 		});