Skip to content

Commit 25cdfa9

Browse files
authored
Update KafkaConsumerRecordGetter.java - safety getAll values from headers
1 parent 3159da1 commit 25cdfa9

File tree

1 file changed

+3
-1
lines changed
  • instrumentation/kafka/kafka-clients/kafka-clients-common-0.11/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal

1 file changed

+3
-1
lines changed

instrumentation/kafka/kafka-clients/kafka-clients-common-0.11/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal/KafkaConsumerRecordGetter.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,9 @@ public String get(@Nullable KafkaProcessRequest carrier, String key) {
4040
@Override
4141
public Iterator<String> getAll(@Nullable KafkaProcessRequest carrier, String key) {
4242
return StreamSupport.stream(carrier.getRecord().headers().headers(key).spliterator(), false)
43-
.map(header -> new String(header.value(), StandardCharsets.UTF_8))
43+
.map(Header::value)
44+
.filter(Objects::nonNull)
45+
.map(value -> new String(value, StandardCharsets.UTF_8))
4446
.iterator();
4547
}
4648
}

0 commit comments

Comments
 (0)