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

This closes apache#2654
liuyuzhong · Dec 5, 2016 · ac0dd2f · ac0dd2f
1 parent 88dc7db
commit ac0dd2f
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();
 		}