commit

kinglong/master/pkg/svc/produce_window.go

@@ -28,6 +28,7 @@ var (
 	yaw              float64
 )
 
+// TODO 参考pjisuv修改
 // PrepareTimeWindowProducerQueue 负责监听所有主题并修改时间窗口
 func PrepareTimeWindowProducerQueue() {
 	log.GlobalLogger.Info("订阅者 goroutine，启动。")