CassandraSinkCluster fix connecting to non-local clusters (#770)

shotover · Aug 30, 2022 · 3ca93e7 · 3ca93e7
1 parent 9ac2931
commit 3ca93e7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/shotover-proxy/src/transforms/cassandra/sink_cluster/mod.rs b/shotover-proxy/src/transforms/cassandra/sink_cluster/mod.rs
@@ -774,7 +774,7 @@ async fn topology_task_process(
             warnings: vec![],
             operation: CassandraOperation::Query {
                 query: Box::new(parse_statement_single(
-                    "SELECT listen_address, rack, data_center, tokens FROM system.local",
+                    "SELECT broadcast_address, rack, data_center, tokens FROM system.local",
                 )),
                 params: Box::new(QueryParams::default()),
             },