diff --git a/event_bus_dtm.go b/event_bus_dtm.go
index 9282a21..dc7e121 100644
--- a/event_bus_dtm.go
+++ b/event_bus_dtm.go
@@ -111,7 +111,7 @@ func (p *DtmEventProducer) Send(ctx context.Context, eventMessages ...DomainEven
 		fd := eventBody.ProtoReflect().Descriptor().Fields().ByName("abs")
 		fv := protoreflect.ValueOfMessage(abs.ProtoReflect())
 		eventBody.ProtoReflect().Set(fd, fv)
-		dtmMsg = dtmMsg.Add("localhost:8082/user_query.userQuery/insertUser", eventBody)
+		dtmMsg.AddTopic("create_user", eventBody)
 	}
 	dtmMsg.BranchHeaders = map[string]string{"test_header": "aaasdfa"}
 	dtmcli.SetBarrierTableName("myhubdb.barrier")