diff --git a/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/AbstractKafkaTest.java b/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/AbstractKafkaTest.java
index f1e52be4..4d621e10 100644
--- a/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/AbstractKafkaTest.java
+++ b/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/AbstractKafkaTest.java
@@ -13,7 +13,7 @@ public abstract class AbstractKafkaTest {
     public static String topic = "example";
     public static Integer partition = null;
     public static String groupId    = "g1";
-    public static String servers    = "slave1.test.apitops.com:6667,slave2.test.apitops.com:6667,slave3.test.apitops.com:6667";
+    public static String servers    = "slave1:6667,slave2:6667,slave3:6667";
 
     public void sleep(long time) {
         try {
diff --git a/kafka/src/main/resources/kafka.yml b/kafka/src/main/resources/kafka.yml
index b46f123c..ab214319 100644
--- a/kafka/src/main/resources/kafka.yml
+++ b/kafka/src/main/resources/kafka.yml
@@ -1,10 +1,10 @@
-servers: slave1.test.apitops.com:6667,slave2.test.apitops.com:6667,slave3.test.apitops.com:6667
+servers: slave1:6667,slave2:6667,slave3:6667
 retries: 0
 batchSize: 16384
 lingerMs: 1
 bufferMemory: 33554432
 # canal的批次大小，单位 k
-canalBatchSize: 5
+canalBatchSize: 50
 
 canalDestinations:
   - canalDestination: example