milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Disable kafka msgstream ut (#19260) 

Signed-off-by: yun.zhang <yun.zhang@zilliz.com>

Signed-off-by: yun.zhang <yun.zhang@zilliz.com>
pull/19275/head
jaime 2022-09-19 16:24:51 +08:00 committed by GitHub
parent 3759f23f88
commit 8ac30397dd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/mq/msgstream/mq_kafka_msgstream_test.go
View File

@ -103,7 +103,12 @@ import (
// assert.Equal(t, o3.BeginTs, p3.BeginTs) // assert.Equal(t, o3.BeginTs, p3.BeginTs)
//} //}
func skipTest(t *testing.T) {
t.Skip("skip kafka test")
}
func TestStream_KafkaMsgStream_SeekToLast(t *testing.T) { func TestStream_KafkaMsgStream_SeekToLast(t *testing.T) {
skipTest(t)
kafkaAddress := getKafkaBrokerList() kafkaAddress := getKafkaBrokerList()
c := funcutil.RandomString(8) c := funcutil.RandomString(8)
producerChannels := []string{c} producerChannels := []string{c}
@ -179,6 +184,7 @@ func TestStream_KafkaMsgStream_SeekToLast(t *testing.T) {
} }
func TestStream_KafkaTtMsgStream_Seek(t *testing.T) { func TestStream_KafkaTtMsgStream_Seek(t *testing.T) {
skipTest(t)
kafkaAddress := getKafkaBrokerList() kafkaAddress := getKafkaBrokerList()
c1 := funcutil.RandomString(8) c1 := funcutil.RandomString(8)
producerChannels := []string{c1} producerChannels := []string{c1}
@ -291,6 +297,7 @@ func TestStream_KafkaTtMsgStream_Seek(t *testing.T) {
} }
func TestStream_KafkaTtMsgStream_1(t *testing.T) { func TestStream_KafkaTtMsgStream_1(t *testing.T) {
skipTest(t)
kafkaAddress := getKafkaBrokerList() kafkaAddress := getKafkaBrokerList()
c1 := funcutil.RandomString(8) c1 := funcutil.RandomString(8)
c2 := funcutil.RandomString(8) c2 := funcutil.RandomString(8)
@ -336,6 +343,7 @@ func TestStream_KafkaTtMsgStream_1(t *testing.T) {
} }
func TestStream_KafkaTtMsgStream_2(t *testing.T) { func TestStream_KafkaTtMsgStream_2(t *testing.T) {
skipTest(t)
kafkaAddress := getKafkaBrokerList() kafkaAddress := getKafkaBrokerList()
c1 := funcutil.RandomString(8) c1 := funcutil.RandomString(8)
c2 := funcutil.RandomString(8) c2 := funcutil.RandomString(8)
@ -392,6 +400,7 @@ func TestStream_KafkaTtMsgStream_2(t *testing.T) {
} }
func TestStream_KafkaTtMsgStream_DataNodeTimetickMsgstream(t *testing.T) { func TestStream_KafkaTtMsgStream_DataNodeTimetickMsgstream(t *testing.T) {
skipTest(t)
kafkaAddress := getKafkaBrokerList() kafkaAddress := getKafkaBrokerList()
c1 := funcutil.RandomString(8) c1 := funcutil.RandomString(8)
p1Channels := []string{c1} p1Channels := []string{c1}