diff --git a/service/raft/group0_state_machine.cc b/service/raft/group0_state_machine.cc
index edb6b09f8a..827862bcb2 100644
--- a/service/raft/group0_state_machine.cc
+++ b/service/raft/group0_state_machine.cc
@@ -57,7 +57,7 @@ group0_state_machine::group0_state_machine(raft_group0_client& client, migration
         group0_server_accessor server_accessor, gms::gossiper& gossiper, gms::feature_service& feat,
         bool topology_change_enabled)
     : _client(client), _mm(mm), _sp(sp), _ss(ss), _topology_change_enabled(topology_change_enabled)
-    , _state_id_handler(sp.local_db(), gossiper, server_accessor)
+    , _state_id_handler(sp.local_db(), gossiper, server_accessor), _feature_service(feat)
     , _topology_on_raft_support_listener(feat.supports_consistent_topology_changes.when_enabled([this] () noexcept {
         // Using features to decide whether to start fetching topology snapshots
         // or not is technically not correct because we also use features to guard
@@ -322,6 +322,9 @@ future<> group0_state_machine::load_snapshot(raft::snapshot_id id) {
     // memory and thus needs to be protected with apply mutex
     auto read_apply_mutex_holder = co_await _client.hold_read_apply_mutex(_abort_source);
     co_await _ss.topology_state_load();
+    if (_feature_service.compression_dicts) {
+        co_await _ss.compression_dictionary_updated_callback();
+    }
     _ss._topology_state_machine.event.broadcast();
 }
 
diff --git a/service/raft/group0_state_machine.hh b/service/raft/group0_state_machine.hh
index 976753af90..6dfcd93992 100644
--- a/service/raft/group0_state_machine.hh
+++ b/service/raft/group0_state_machine.hh
@@ -106,6 +106,7 @@ class group0_state_machine : public raft_state_machine {
     abort_source _abort_source;
     bool _topology_change_enabled;
     group0_state_id_handler _state_id_handler;
+    gms::feature_service& _feature_service;
     gms::feature::listener_registration _topology_on_raft_support_listener;
 
     modules_to_reload get_modules_to_reload(const std::vector<canonical_mutation>& mutations);
diff --git a/test/topology_custom/test_rpc_compression.py b/test/topology_custom/test_rpc_compression.py
index a56a9dd2dd..e6b3e51ac2 100644
--- a/test/topology_custom/test_rpc_compression.py
+++ b/test/topology_custom/test_rpc_compression.py
@@ -208,11 +208,15 @@ async def test_external_dicts(manager: ManagerClient) -> None:
         assert approximately_equal(compressed, expected_ratio * volume, 0.8)
 
     await with_retries(functools.partial(test_once, "lz4", 0.5), timeout=600)
-
     await live_update_config(manager, servers, "internode_compression_zstd_max_cpu_fraction", "1.0"),
-
     await with_retries(functools.partial(test_once, "zstd", 0.25), timeout=600)
 
+    # Test that the dicts are loaded on startup.
+    await asyncio.gather(*[manager.server_stop_gracefully(s.server_id) for s in servers])
+    await asyncio.gather(*[manager.server_update_config(s.server_id, 'rpc_dict_training_when', 'never') for s in servers])
+    await asyncio.gather(*[manager.server_start(s.server_id) for s in servers])
+    await with_retries(functools.partial(test_once, "lz4", 0.5), timeout=10)
+
 # Similar to test_external_dicts, but simpler.
 @pytest.mark.asyncio
 async def test_external_dicts_sanity(manager: ManagerClient) -> None: