yihao.dai 51f69f32d0
feat: Add CDC support (#44124)
This PR implements a new CDC service for Milvus 2.6, providing log-based
cross-cluster replication.

issue: https://github.com/milvus-io/milvus/issues/44123

---------

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
Signed-off-by: chyezh <chyezh@outlook.com>
Co-authored-by: chyezh <chyezh@outlook.com>
2025-09-16 16:32:01 +08:00

36 lines
971 B
Go

package pulsar
import (
"testing"
"github.com/stretchr/testify/assert"
"github.com/milvus-io/milvus-proto/go-api/v2/commonpb"
"github.com/milvus-io/milvus/pkg/v2/streaming/util/message"
"github.com/milvus-io/milvus/pkg/v2/streaming/walimpls"
"github.com/milvus-io/milvus/pkg/v2/streaming/walimpls/registry"
"github.com/milvus-io/milvus/pkg/v2/util/paramtable"
)
func TestMain(m *testing.M) {
paramtable.Init()
m.Run()
}
func TestRegistry(t *testing.T) {
registeredB := registry.MustGetBuilder(message.WALNamePulsar)
assert.NotNil(t, registeredB)
assert.Equal(t, message.WALNamePulsar, registeredB.Name())
id, err := message.UnmarshalMessageID(&commonpb.MessageID{
WALName: commonpb.WALName(message.WALNamePulsar),
Id: newMessageIDOfPulsar(1, 2, 3).Marshal(),
})
assert.NoError(t, err)
assert.True(t, id.EQ(newMessageIDOfPulsar(1, 2, 3)))
}
func TestPulsar(t *testing.T) {
walimpls.NewWALImplsTestFramework(t, 100, &builderImpl{}).Run()
}