Fix "trace in value" failing when hitting a tombstone

patschuh · Oct 7, 2021 · e5106a1 · e5106a1
1 parent 013ce35
commit e5106a1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/at/esque/kafka/Controller.java b/src/main/java/at/esque/kafka/Controller.java
@@ -416,6 +416,9 @@ private ListCell<String> topicListCellFactory() {
                             backGroundTaskHolder.setBackGroundTaskDescription("tracing in Value: " + traceInput.getSearch());
                             Pattern pattern = Pattern.compile(traceInput.getSearch());
                             trace(topicMessageTypeConfig, consumerConfig, (ConsumerRecord cr) -> {
+                                if (cr.value() == null){
+                                    return false;
+                                }
                                 Matcher matcher = pattern.matcher(cr.value().toString());
                                 return matcher.find();
                             }, null, traceInput.getEpoch());