更新

@@ -96,6 +96,7 @@ func StartConsumer(ctx context.Context) (func(), error) {
 			if err := consumerGroup.Consume(ctx, consumer.topics, consumer); err != nil {
 			if err := consumerGroup.Consume(ctx, consumer.topics, consumer); err != nil {
 				logs.Error("consumerGroup err:%s \n", err)
 				logs.Error("consumerGroup err:%s \n", err)
 			}
 			}
+			consumer.ready = make(chan bool)
 		}
 		}
 	}()
 	}()
 	//等待 consumerGroup 设置完成
 	//等待 consumerGroup 设置完成