This is an automated email from the ASF dual-hosted git repository.
kfaraz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 6e19ce5e69f Handle null values in `KafkaStringHeaderReader` (#16192)
6e19ce5e69f is described below
commit 6e19ce5e69f0555d90645b49873db0c288d9dd01
Author: Aru Raghuwanshi <[email protected]>
AuthorDate: Sat Mar 23 00:35:55 2024 -0700
Handle null values in `KafkaStringHeaderReader` (#16192)
---
.../apache/druid/data/input/kafkainput/KafkaStringHeaderReader.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/data/input/kafkainput/KafkaStringHeaderReader.java
b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/data/input/kafkainput/KafkaStringHeaderReader.java
index 4ddbf52d41d..91ae7e8f2df 100644
---
a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/data/input/kafkainput/KafkaStringHeaderReader.java
+++
b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/data/input/kafkainput/KafkaStringHeaderReader.java
@@ -48,8 +48,11 @@ public class KafkaStringHeaderReader implements
KafkaHeaderReader
public List<Pair<String, Object>> read()
{
List<Pair<String, Object>> events = new ArrayList<>();
+
for (Header hdr : headers) {
- String s = new String(hdr.value(), this.encoding);
+ byte[] value = hdr.value();
+
+ String s = value == null ? null : new String(value, this.encoding);
String newKey = this.headerLabelPrefix + hdr.key();
events.add(Pair.of(newKey, s));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
