tools/offline_log_viewer: support v=4 group_configuration

mmaslankaprv · Dec 15, 2022 · d8d85c4 · d8d85c4
1 parent ba26cd7
commit d8d85c4
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/tools/offline_log_viewer/model.py b/tools/offline_log_viewer/model.py
@@ -74,13 +74,25 @@ def read_broker(rdr):
     return br
 
 
+def read_configuration_update(rdr):
+    return {
+        'replicas_to_add': rdr.read_vector(read_vnode),
+        'replicas_to_remove': rdr.read_vector(read_vnode)
+    }
+
+
 def read_raft_config(rdr):
     cfg = {}
     cfg['version'] = rdr.read_int8()
     cfg['brokers'] = rdr.read_vector(read_broker)
     cfg['current_config'] = read_group_nodes(rdr)
     cfg['prev_config'] = rdr.read_optional(read_group_nodes)
     cfg['revision'] = rdr.read_int64()
+
+    if cfg['version'] >= 4:
+        cfg['configuration_update'] = rdr.read_optional(
+            lambda ordr: read_configuration_update(ordr))
+
     return cfg