[Issue 7407] NPE with tombstones (apache#7408)

Added check to prevent NPE when a tombstone (null value) is produced. Fixes apache#7407
vzhikserg · Jul 6, 2020 · 90c2f4a · 90c2f4a
1 parent 53c50c1
commit 90c2f4a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java
@@ -166,7 +166,7 @@ private void init(ConsumerConfigurationData<?> conf) {
     public void updateNumMsgsReceived(Message<?> message) {
         if (message != null) {
             numMsgsReceived.increment();
-            numBytesReceived.add(message.getData().length);
+            numBytesReceived.add(message.getData() == null ? 0 : message.getData().length);
         }
     }