[hotfix] [kafka] Fix RackAwareMode instantiation in Kafka 0.10 tests

This closes #2654
apache · Oct 26, 2016 · 307eae6 · 307eae6
1 parent 11fa089
commit 307eae6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...0/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java b/...0/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
@@ -288,7 +288,7 @@ public void createTestTopic(String topic, int numberOfPartitions, int replicatio
 
 		ZkUtils zkUtils = getZkUtils();
 		try {
-			AdminUtils.createTopic(zkUtils, topic, numberOfPartitions, replicationFactor, topicConfig, new kafka.admin.RackAwareMode.Enforced$());
+			AdminUtils.createTopic(zkUtils, topic, numberOfPartitions, replicationFactor, topicConfig, kafka.admin.RackAwareMode.Enforced$.MODULE$);
 		} finally {
 			zkUtils.close();
 		}