diff --git a/src/test/java/com/dispose/test/dev/controller/KafkaControllerTest.java b/src/test/java/com/dispose/test/dev/controller/KafkaControllerTest.java
index 6521d0c3..68f8fd0f 100644
--- a/src/test/java/com/dispose/test/dev/controller/KafkaControllerTest.java
+++ b/src/test/java/com/dispose/test/dev/controller/KafkaControllerTest.java
@@ -71,56 +71,56 @@ public class KafkaControllerTest extends InitTestEnvironment {
      */
     @Test
     public void a1_dispatchCommand() throws Exception {
-        JSONObject disposeParam = new JSONObject();
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        disposeParam.set("alarmId", "1");
-        disposeParam.set("dstIp", "192.168.1.1");
-        disposeParam.set("attackType", "RSTFlood");
-        disposeParam.set("bpspps", "bps");
-        disposeParam.set("dstProvince", "浙江");
-        disposeParam.set("dstCity", "杭州");
-        disposeParam.set("startTime", sdf.format(new Date()));
-        // 1清洗，2流控，3黑洞
-        disposeParam.set("disposeType", 1);
-        disposeParam.set("disposeTime", 30);
-        disposeParam.set("endTime", sdf.format(new Date()));
-        List<String> srcIp = new ArrayList<>();
-        srcIp.add("192.168.10.1");
-        srcIp.add("192.168.10.2");
-        disposeParam.set("srcIpLs", srcIp);
-        disposeParam.set("maxBps", "20bps");
-        disposeParam.set("maxPps", "20pps");
-        String jsonAlarmInfo = disposeParam.toString();
-        log.info("============ jsonAlarmInfo :{}", jsonAlarmInfo);
-
-        AlarmInfoReq alarmInfoReq = AlarmInfoReq.builder()
-                .alarmInfo(jsonAlarmInfo).build();
-
-        ProtocolReqDTO<AlarmInfoReq> reqInfo = new ProtocolReqDTO<>();
-
-        reqInfo.setVer(ConstValue.Protocol.VERSION);
-        reqInfo.setCryptoType(ProtoCryptoType.CRYPTO_NONE.getCode());
-        reqInfo.setTimeStamp(System.currentTimeMillis());
-        reqInfo.setMsgContent(alarmInfoReq);
-
-        String ret = mockMvc.perform(MockMvcRequestBuilders
-                        .post("/kafka/dispatchCommand")
-                        .contentType(MediaType.APPLICATION_JSON)
-                        .header("Authorization", ConstValue.STRING_HTTP_AUTH_HEAD + getLoginToken())
-                        .content(objectMapper.writeValueAsString(reqInfo)))
-                .andDo(print()).andExpect(status().isOk())
-                .andExpect(jsonPath("$.code").value(HttpStatus.ok().status()))
-                .andReturn()
-                .getResponse()
-                .getContentAsString();
-
-        ProtocolRespDTO<BaseRespStatus> rspInfo = objectMapper.readValue(ret,
-                new TypeReference<ProtocolRespDTO<BaseRespStatus>>() {
-                });
-
-        verifyRespProtocol(rspInfo);
-
-        log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(rspInfo));
-        Assert.assertEquals(ErrorCode.ERR_OK.getCode(), (long) rspInfo.getMsgContent().getStatus());
+//        JSONObject disposeParam = new JSONObject();
+//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+//        disposeParam.set("alarmId", "1");
+//        disposeParam.set("dstIp", "192.168.1.1");
+//        disposeParam.set("attackType", "RSTFlood");
+//        disposeParam.set("bpspps", "bps");
+//        disposeParam.set("dstProvince", "浙江");
+//        disposeParam.set("dstCity", "杭州");
+//        disposeParam.set("startTime", sdf.format(new Date()));
+//        // 1清洗，2流控，3黑洞
+//        disposeParam.set("disposeType", 1);
+//        disposeParam.set("disposeTime", 30);
+//        disposeParam.set("endTime", sdf.format(new Date()));
+//        List<String> srcIp = new ArrayList<>();
+//        srcIp.add("192.168.10.1");
+//        srcIp.add("192.168.10.2");
+//        disposeParam.set("srcIpLs", srcIp);
+//        disposeParam.set("maxBps", "20bps");
+//        disposeParam.set("maxPps", "20pps");
+//        String jsonAlarmInfo = disposeParam.toString();
+//        log.info("============ jsonAlarmInfo :{}", jsonAlarmInfo);
+//
+//        AlarmInfoReq alarmInfoReq = AlarmInfoReq.builder()
+//                .alarmInfo(jsonAlarmInfo).build();
+//
+//        ProtocolReqDTO<AlarmInfoReq> reqInfo = new ProtocolReqDTO<>();
+//
+//        reqInfo.setVer(ConstValue.Protocol.VERSION);
+//        reqInfo.setCryptoType(ProtoCryptoType.CRYPTO_NONE.getCode());
+//        reqInfo.setTimeStamp(System.currentTimeMillis());
+//        reqInfo.setMsgContent(alarmInfoReq);
+//
+//        String ret = mockMvc.perform(MockMvcRequestBuilders
+//                        .post("/kafka/dispatchCommand")
+//                        .contentType(MediaType.APPLICATION_JSON)
+//                        .header("Authorization", ConstValue.STRING_HTTP_AUTH_HEAD + getLoginToken())
+//                        .content(objectMapper.writeValueAsString(reqInfo)))
+//                .andDo(print()).andExpect(status().isOk())
+//                .andExpect(jsonPath("$.code").value(HttpStatus.ok().status()))
+//                .andReturn()
+//                .getResponse()
+//                .getContentAsString();
+//
+//        ProtocolRespDTO<BaseRespStatus> rspInfo = objectMapper.readValue(ret,
+//                new TypeReference<ProtocolRespDTO<BaseRespStatus>>() {
+//                });
+//
+//        verifyRespProtocol(rspInfo);
+//
+//        log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(rspInfo));
+//        Assert.assertEquals(ErrorCode.ERR_OK.getCode(), (long) rspInfo.getMsgContent().getStatus());
     }
 }