diff --git a/src/main/java/io/connect/scylladb/ScyllaDbSinkConnector.java b/src/main/java/io/connect/scylladb/ScyllaDbSinkConnector.java
index b1e0a2b..c18d37d 100644
--- a/src/main/java/io/connect/scylladb/ScyllaDbSinkConnector.java
+++ b/src/main/java/io/connect/scylladb/ScyllaDbSinkConnector.java
@@ -53,7 +53,7 @@ public void start(Map<String, String> settings) {
         CreateKeyspace createKeyspace = SchemaBuilder.createKeyspace(config.keyspace)
                 .ifNotExists()
                 .withReplicationOptions(ImmutableMap.of(
-                "class", (Object) "SimpleStrategy",
+                "class", (Object) "NetworkTopologyStrategy",
                 "replication_factor", config.keyspaceReplicationFactor
                   ))
             .withDurableWrites(true);