Merge branch '7.5.x' into 7.6.x by zhaochun-ma

confluentinc · Jan 24, 2024 · dde119f · dde119f
2 parents 35a72cf + 1879995
commit dde119f
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/schema-serializer/src/main/java/io/confluent/kafka/formatter/SchemaMessageFormatter.java b/schema-serializer/src/main/java/io/confluent/kafka/formatter/SchemaMessageFormatter.java
@@ -271,8 +271,12 @@ public void writeTo(ConsumerRecord<byte[], byte[]> consumerRecord, PrintStream o
       }
       if (printValueId) {
         output.write(idSeparator);
-        int schemaId = schemaIdFor(consumerRecord.value());
-        output.print(schemaId);
+        if (consumerRecord.value() != null) {
+          int schemaId = schemaIdFor(consumerRecord.value());
+          output.print(schemaId);
+        } else {
+          output.write(NULL_BYTES);
+        }
       }
       output.write(lineSeparator);
     } catch (IOException ioe) {