diff --git a/pom.xml b/pom.xml
index c03d44f..d7302f3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -8,17 +8,22 @@
     <artifactId>kafka-topic-client</artifactId>
     <version>1.0-SNAPSHOT</version>
 
+    <properties>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
+    </properties>
+
     <dependencies>
 
         <dependency>
             <groupId>org.apache.kafka</groupId>
-            <artifactId>kafka_2.11</artifactId>
-            <version>0.9.0.0</version>
+            <artifactId>kafka_2.12</artifactId>
+            <version>1.0.0</version>
         </dependency>
         <dependency>
             <groupId>com.101tec</groupId>
             <artifactId>zkclient</artifactId>
-            <version>0.7</version>
+            <version>0.10</version>
         </dependency>
 
     </dependencies>
@@ -49,4 +54,4 @@
             </plugin>
         </plugins>
     </build>
-</project>
\ No newline at end of file
+</project>
diff --git a/src/main/java/Client.java b/src/main/java/Client.java
index 91a9e30..010107b 100644
--- a/src/main/java/Client.java
+++ b/src/main/java/Client.java
@@ -6,6 +6,8 @@
 import java.util.concurrent.TimeUnit;
 
 import kafka.admin.AdminUtils;
+import kafka.admin.RackAwareMode;
+import kafka.admin.RackAwareMode.Safe$;
 import kafka.utils.ZKStringSerializer$;
 import kafka.utils.ZkUtils;
 
@@ -15,6 +17,7 @@ public class Client {
   final static boolean resetTopic = Boolean.parseBoolean(System.getenv("RESET_TOPIC"));
   final static int partitions = Integer.parseInt(System.getenv("NUM_PARTITIONS"));
   final static int replication = Integer.parseInt(System.getenv("NUM_REPLICAS"));
+  final static RackAwareMode rackAwareMode = Safe$.MODULE$;
 
   final static int nRetries = Integer.parseInt(System.getenv("NUM_CREATE_RETRIES"));
 
@@ -64,7 +67,7 @@ private static void tryCreate(ZkUtils zkUtils, String topicName, int nRetriesLef
     System.out.println("Creating topic " + topicName);
     Properties topicConfig = new Properties(); // add per-topic configurations settings here
     try {
-      AdminUtils.createTopic(zkUtils, topicName, partitions, replication, topicConfig);
+      AdminUtils.createTopic(zkUtils, topicName, partitions, replication, topicConfig, rackAwareMode);
     } catch (Exception e) {
       if (nRetriesLeft <= 0) {
         throw new RuntimeException("Failed to create topic \"" + topicName + "\". Is Kafka and Zookeeper running?");