fix: broker new consumer group run

gkafka/kafka.go

@@ -3,6 +3,7 @@ package gkafka
 import (
 	"context"
 	"errors"
+	"fmt"
 	"time"
 
 	"github.com/Shopify/sarama"
@@ -87,8 +88,9 @@ func (k *kafkaImpl) Subscribe(ctx context.Context, topic string, groupID string,
 
 	consumerGroup, err := sarama.NewConsumerGroupFromClient(opt.Name, k.client)
 	if err != nil {
-		return err
+		panic(fmt.Errorf("new kafka consumer name:%s err:%s", opt.Name, err.Error()))
 	}
+
 	defer func() {
 		_ = consumerGroup.Close()
 	}()

gpulsar/pulsar.go

@@ -3,6 +3,7 @@ package gpulsar
 import (
 	"context"
 	"errors"
+	"fmt"
 	"strings"
 	"time"
 
@@ -119,8 +120,9 @@ func (p *pulsarImpl) Subscribe(ctx context.Context, topic string, channel string
 	}
 
 	if err != nil {
-		return err
+		panic(fmt.Errorf("new pulsar consumer name:%s err:%s", opt.Name, err.Error()))
 	}
+
 	defer consumer.Close()
 
 	done := make(chan struct{}, opt.ConcurrencySize)

readme.md

@@ -21,4 +21,4 @@ https://pulsar.apache.org/docs/zh-CN/client-libraries-go/
 
     For specific usage, refer to gpulsar/gredis test
     kafka consumer groups require Version to be >= V0_10_2_0
-    if lower than V0_10_2_0, please use go-god/broker v1.1.1
+    if lower than V0_10_2_0, please use go-god/broker v1.1.2