feat: improve rollback mitigation log and vbucket discovery

couchbase/rollback_mitigation.go

@@ -3,7 +3,9 @@ package couchbase
 import (
 	"context"
 	"errors"
+	"fmt"
 	"reflect"
+	"strings"
 	"time"
 
 	"github.com/couchbase/gocbcore/v10"
@@ -185,6 +187,19 @@ func (r *rollbackMitigation) startObserve(groupID int) {
 
 		uuIDMap[vbID] = failoverLogs[0].VbUUID
 
+		var failoverInfos []string
+		for index, failoverLog := range failoverLogs {
+			failoverInfos = append(
+				failoverInfos,
+				fmt.Sprintf("index: %v, vbUUID: %v, seqNo: %v", index, failoverLog.VbUUID, failoverLog.SeqNo),
+			)
+		}
+
+		logger.Log.Debug(
+			"observing vbID: %v, vbUUID: %v, failoverInfo: %v",
+			vbID, uuIDMap[vbID], strings.Join(failoverInfos, ", "),
+		)
+
 		return true
 	})
 

stream/vbucket_discovery.go

@@ -49,7 +49,7 @@ func (s *vBucketDiscovery) Get() []uint16 {
 	start := readyToStreamVBuckets[0]
 	end := readyToStreamVBuckets[len(readyToStreamVBuckets)-1]
 
-	logger.Log.Debug(
+	logger.Log.Info(
 		"member: %v/%v, vbucket range: %v-%v",
 		receivedInfo.MemberNumber, receivedInfo.TotalMembers,
 		start, end,