diff --git a/src/main/java/cn/ac/iie/bean/CollectProtocolRecordLog.java b/src/main/java/cn/ac/iie/bean/CollectProtocolRecordLog.java
index 43b7d00..a4d82e8 100644
--- a/src/main/java/cn/ac/iie/bean/CollectProtocolRecordLog.java
+++ b/src/main/java/cn/ac/iie/bean/CollectProtocolRecordLog.java
@@ -1,7 +1,7 @@
 package cn.ac.iie.bean;
 
 /**
- * 除radius之外
+ * 除radius之外，通联日志类
  *
  * @author qidaijie
  */
diff --git a/src/main/java/cn/ac/iie/bean/SecurityPolicyLog.java b/src/main/java/cn/ac/iie/bean/SecurityPolicyLog.java
index 998182f..799a8bd 100644
--- a/src/main/java/cn/ac/iie/bean/SecurityPolicyLog.java
+++ b/src/main/java/cn/ac/iie/bean/SecurityPolicyLog.java
@@ -1,7 +1,7 @@
 package cn.ac.iie.bean;
 
 /**
- * 策略
+ * 安全策略
  *
  * @author qidaijie
  */
diff --git a/src/main/java/cn/ac/iie/topology/LogFlowWriteTopology.java b/src/main/java/cn/ac/iie/topology/LogFlowWriteTopology.java
index 9f3a54d..c5c5090 100644
--- a/src/main/java/cn/ac/iie/topology/LogFlowWriteTopology.java
+++ b/src/main/java/cn/ac/iie/topology/LogFlowWriteTopology.java
@@ -64,22 +64,22 @@ public class LogFlowWriteTopology {
         builder.setSpout("LogFlowWriteSpout", new CustomizedKafkaSpout(), FlowWriteConfig.SPOUT_PARALLELISM);
 
         switch (FlowWriteConfig.KAFKA_TOPIC) {
-            case "PROXY-POLICY-LOG":
+            case "PROXY-EVENT-LOG":
                 builder.setBolt("ProxyCompletionBolt", new ProxyCompletionBolt(), FlowWriteConfig.DATACENTER_BOLT_PARALLELISM).localOrShuffleGrouping("LogFlowWriteSpout");
                 builder.setBolt("NtcLogSendBolt", new NtcLogSendBolt(), FlowWriteConfig.KAFKA_BOLT_PARALLELISM).localOrShuffleGrouping("ProxyCompletionBolt");
                 break;
 
-            case "COLLECT-RADIUS-RECORD-LOG":
+            case "RADIUS-RECORD-LOG":
                 builder.setBolt("RadiusCompletionBolt", new RadiusCompletionBolt(), FlowWriteConfig.DATACENTER_BOLT_PARALLELISM).localOrShuffleGrouping("LogFlowWriteSpout");
                 builder.setBolt("NtcLogSendBolt", new NtcLogSendBolt(), FlowWriteConfig.KAFKA_BOLT_PARALLELISM).localOrShuffleGrouping("RadiusCompletionBolt");
                 break;
 
-            case "COLLECT-PROTOCOL-RECORD-LOG":
+            case "CONNECTION-RECORD-LOG":
                 builder.setBolt("CollectCompletedBolt", new CollectCompletedBolt(), FlowWriteConfig.DATACENTER_BOLT_PARALLELISM).localOrShuffleGrouping("LogFlowWriteSpout");
                 builder.setBolt("NtcLogSendBolt", new NtcLogSendBolt(), FlowWriteConfig.KAFKA_BOLT_PARALLELISM).localOrShuffleGrouping("CollectCompletedBolt");
                 break;
 
-            case "SECURITY-POLICY-LOG":
+            case "SECURITY-EVENT-LOG":
                 builder.setBolt("SecurityCompletionBolt", new SecurityCompletionBolt(), FlowWriteConfig.DATACENTER_BOLT_PARALLELISM).localOrShuffleGrouping("LogFlowWriteSpout");
                 builder.setBolt("NtcLogSendBolt", new NtcLogSendBolt(), FlowWriteConfig.KAFKA_BOLT_PARALLELISM).localOrShuffleGrouping("SecurityCompletionBolt");
                 break;