From 6dd72d40ee061d87dceae03beb02e93a1fd5efdd Mon Sep 17 00:00:00 2001
From: WYAOBO <50188429+WYAOBO@users.noreply.github.com>
Date: Fri, 2 Sep 2022 18:04:14 +0800
Subject: [PATCH] =?UTF-8?q?Update=20KnowStreaming=20Task=E6=A8=A1=E5=9D=97?=
 =?UTF-8?q?=E7=AE=80=E4=BB=8B.md?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 docs/dev_guide/KnowStreaming Task模块简介.md | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/docs/dev_guide/KnowStreaming Task模块简介.md b/docs/dev_guide/KnowStreaming Task模块简介.md
index b1316067..abe2b81d 100644
--- a/docs/dev_guide/KnowStreaming Task模块简介.md	
+++ b/docs/dev_guide/KnowStreaming Task模块简介.md	
@@ -199,16 +199,21 @@ public abstract class AbstractDispatchTask<E extends Comparable & EntifyIdInterf
 
 ```java
 // 继承AbstractDispatchTask的抽象类，对Kafka集群进行负载均衡执行 
-public abstract class AbstractClusterPhyDispatchTask extends AbstractDispatchTask<ClusterPhy> {   
+public abstract class AbstractClusterPhyDispatchTask extends AbstractDispatchTask<ClusterPhy> {
+
   // 执行被分配的任务，具体由子类实现    
-  protected abstract TaskResult processSubTask(ClusterPhy clusterPhy, long triggerTimeUnitMs) throws Exception;     	// 返回所有的Kafka集群   
+  protected abstract TaskResult processSubTask(ClusterPhy clusterPhy, long triggerTimeUnitMs) throws Exception;     	
+  
+  // 返回所有的Kafka集群   
   @Override    
   public List<ClusterPhy> listAllTasks() {        
     return clusterPhyService.listAllClusters();   
   }     
+  
   // 执行被分配给该KS主机的Kafka集群任务   
   @Override   
   public TaskResult processTask(List<ClusterPhy> subTaskList, long triggerTimeUnitMs) {        // ...     }
+  
 }   
 ```