feat: 规划消费者

consumer.go

@@ -58,9 +58,9 @@ func (c *Consumer) init() error {
 // Consume 消费消息
 func (c *Consumer) Consume(dataHandler IConsumeDataHandler) {
 	ctx := context.Background()
+	handler := consumerGroupHandler{name: c.consumerGroup, handler: dataHandler}
 	for {
 		topics := []string{c.consumerGroup}
-		handler := consumerGroupHandler{name: c.consumerGroup, handler: dataHandler}
 		if err := c.consumerGroupInstance.Consume(ctx, topics, handler); nil != err {
 			handler.handler.Exception(err)
 		}