update code

server/node.go

@@ -99,7 +99,7 @@ func (n *Node) attachKafkaConsumer(ctx context.Context, taskCh chan *odysseus.Ta
 	// split broker to list
 	brokers := strings.Split(n.conf.Kafka.Brokers, ";")
 
-	client, err := sarama.NewConsumerGroup(brokers, "group", config)
+	client, err := sarama.NewConsumerGroup(brokers, "test", config)
 	if err != nil {
 		log.WithError(err).Error("creating consumer group client failed")
 		return nil, err