Fix unit test code

Signed-off-by: Congqi Xia <[email protected]>
milvus-io · Apr 23, 2024 · 73be810 · 73be810
1 parent 61f32af
commit 73be810
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/mq/pulsar/puslar_test.go → mq/pulsar/pulsar_test.go b/mq/pulsar/puslar_test.go → mq/pulsar/pulsar_test.go
@@ -8,6 +8,7 @@ import (
 	"time"
 
 	"github.com/apache/pulsar-client-go/pulsar"
+	"github.com/milvus-io/birdwatcher/mq/ifc"
 	"github.com/stretchr/testify/assert"
 )
 
@@ -44,7 +45,9 @@ func TestConsumer(t *testing.T) {
 		}
 	}
 
-	c, err := NewPulsarConsumer(address, topic, "gid")
+	c, err := NewPulsarConsumer(address, topic, "gid", ifc.MqOption{
+		SubscriptionInitPos: ifc.SubscriptionPositionLatest,
+	})
 	if err != nil {
 		t.Fatal(err)
 	}