diff --git a/app.py b/app.py
index 1a3ac66..b554f58 100644
--- a/app.py
+++ b/app.py
@@ -66,6 +66,8 @@ class XProcess(Process):
                 self.log.info(f'进程{self.partition} 结束')
 
                 break
+            elif type_ == 'test':
+                self.log.info(f'消费分区{self.partition} -> {msg}')
             else:
                 continue