FIX:sort consumer list to prevent data conflict

meitu · Jun 27, 2017 · bf8d608 · bf8d608
1 parent 60916f7
commit bf8d608
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/zk_group_storage.go b/zk_group_storage.go
@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"sort"
 	"strconv"
 	"time"
 
@@ -243,7 +244,8 @@ func (s *ZKGroupStorage) GetConsumerList(group string) ([]string, error) {
 	if err != nil {
 		return nil, err
 	}
-	return consumerList, err
+	sort.Strings(consumerList)
+	return consumerList, nil
 }
 
 func (s *ZKGroupStorage) CommitOffset(group, topic string, partition int32, offset int64) error {