tools[log_viewer]: support kafka_internal ns

Some topics are in kafka_internal ns like tx (transaction coordinator) and id_allocator.
redpanda-data · Jun 30, 2022 · a1cd943 · a1cd943
1 parent 7f0d681
commit a1cd943
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tools/offline_log_viewer/viewer.py b/tools/offline_log_viewer/viewer.py
@@ -34,7 +34,7 @@ def print_controller(store):
 
 def print_kafka(store, topic):
     for ntp in store.ntps:
-        if ntp.nspace == "kafka":
+        if ntp.nspace.startswith("kafka"):
             if topic and ntp.topic != topic:
                 continue
 
@@ -46,7 +46,7 @@ def print_kafka(store, topic):
 
 def print_kafka_records(store, topic):
     for ntp in store.ntps:
-        if ntp.nspace == "kafka":
+        if ntp.nspace.startswith("kafka"):
             if topic and ntp.topic != topic:
                 continue