diff --git a/db/view/view.cc b/db/view/view.cc
index ef242fa0b1..2d890145ba 100644
--- a/db/view/view.cc
+++ b/db/view/view.cc
@@ -1546,7 +1546,7 @@ bool needs_static_row(const mutation_partition& mp, const std::vector<view_and_b
 // If the assumption that the given base token belongs to this replica
 // does not hold, we return an empty optional.
 static std::optional<gms::inet_address>
-get_view_natural_endpoint(const locator::vnode_effective_replication_map_ptr& erm, bool network_topology,
+get_view_natural_endpoint(const locator::effective_replication_map_ptr& erm, bool network_topology,
         const dht::token& base_token, const dht::token& view_token) {
     auto& topology = erm->get_token_metadata_ptr()->get_topology();
     auto my_address = utils::fb_utilities::get_broadcast_address();
@@ -1630,9 +1630,8 @@ future<> view_update_generator::mutate_MV(
     co_await max_concurrent_for_each(view_updates, max_concurrent_updates,
             [this, base_token, &stats, &cf_stats, tr_state, &pending_view_updates, allow_hints, wait_for_all] (frozen_mutation_and_schema mut) mutable -> future<> {
         auto view_token = dht::get_token(*mut.s, mut.fm.key());
-        auto& keyspace_name = mut.s->ks_name();
-        auto& ks = _proxy.local().local_db().find_keyspace(keyspace_name);
-        auto ermp = ks.get_effective_replication_map();
+        auto ermp = mut.s->table().get_effective_replication_map();
+        auto& ks = _proxy.local().local_db().find_keyspace(mut.s->ks_name());
         bool network_topology = dynamic_cast<const locator::network_topology_strategy*>(&ks.get_replication_strategy());
         auto target_endpoint = get_view_natural_endpoint(ermp, network_topology, base_token, view_token);
         auto remote_endpoints = ermp->get_pending_endpoints(view_token);
diff --git a/test/topology_experimental_raft/test_mv_tablets.py b/test/topology_experimental_raft/test_mv_tablets.py
index df13ecc56e..1d3db4653d 100644
--- a/test/topology_experimental_raft/test_mv_tablets.py
+++ b/test/topology_experimental_raft/test_mv_tablets.py
@@ -30,3 +30,24 @@ async def test_tablet_mv_create(manager: ManagerClient):
     await cql.run_async("CREATE TABLE test.test (pk int PRIMARY KEY, c int)")
     await cql.run_async("CREATE MATERIALIZED VIEW test.tv AS SELECT * FROM test.test WHERE c IS NOT NULL AND pk IS NOT NULL PRIMARY KEY (c, pk)")
     await cql.run_async("DROP KEYSPACE test")
+
+
+@pytest.mark.asyncio
+async def test_tablet_mv_simple(manager: ManagerClient):
+    """A simple test for reading and writing a materialized view on a table
+       stored with tablets on a one-node cluster. Because it's a one-node
+       cluster, we don't don't need any sophisticated mappings or pairings
+       to work correctly for this test to pass - everything is on this single
+       node anyway.
+       Reproduces issue #16209.
+    """
+    servers = [await manager.server_add() for i in range(1)]
+    cql = manager.get_cql()
+
+    await cql.run_async("CREATE KEYSPACE test WITH replication = {'class': 'NetworkTopologyStrategy', 'replication_factor': 1, 'initial_tablets': 100}")
+    await cql.run_async("CREATE TABLE test.test (pk int PRIMARY KEY, c int)")
+    await cql.run_async("CREATE MATERIALIZED VIEW test.tv AS SELECT * FROM test.test WHERE c IS NOT NULL AND pk IS NOT NULL PRIMARY KEY (c, pk) WITH SYNCHRONOUS_UPDATES = TRUE")
+    await cql.run_async("INSERT INTO test.test (pk, c) VALUES (2, 3)")
+    # We used SYNCHRONOUS_UPDATES=TRUE, so the view should be updated:
+    assert [(3,2)] == list(await cql.run_async("SELECT * FROM test.tv WHERE c=3"))
+    await cql.run_async("DROP KEYSPACE test")