From 93fd6b70f39fab14da2ca693789e4b3426e97665 Mon Sep 17 00:00:00 2001 From: godchen Date: Mon, 1 Feb 2021 19:22:35 +0800 Subject: [PATCH] Fix the error usage of ttmsg Signed-off-by: godchen --- internal/dataservice/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/dataservice/server.go b/internal/dataservice/server.go index b48634f2da..046cf7fff3 100644 --- a/internal/dataservice/server.go +++ b/internal/dataservice/server.go @@ -360,7 +360,7 @@ func (s *Server) startSegmentFlushChannel(ctx context.Context) { func (s *Server) startDDChannel(ctx context.Context) { defer s.serverLoopWg.Done() - ddStream := pulsarms.NewPulsarTtMsgStream(ctx, 1024) + ddStream := pulsarms.NewPulsarMsgStream(ctx, 1024) ddStream.SetPulsarClient(Params.PulsarAddress) ddStream.CreatePulsarConsumers([]string{s.ddChannelName}, Params.DataServiceSubscriptionName, util.NewUnmarshalDispatcher(), 1024) ddStream.Start()