diff --git a/internal/rtmp/rtmp.go b/internal/rtmp/rtmp.go
index afc363a9..b3d7f932 100644
--- a/internal/rtmp/rtmp.go
+++ b/internal/rtmp/rtmp.go
@@ -133,7 +133,7 @@ func streamsHandle(url string) (core.Producer, error) {
 func streamsConsumerHandle(url string) (core.Consumer, func(), error) {
 	cons := flv.NewConsumer()
 	run := func() {
-		wr, err := rtmp.DialPublish(url)
+		wr, err := rtmp.DialPublish(url, cons)
 		if err != nil {
 			return
 		}
diff --git a/pkg/rtmp/client.go b/pkg/rtmp/client.go
index 138d727d..c9e9ad17 100644
--- a/pkg/rtmp/client.go
+++ b/pkg/rtmp/client.go
@@ -35,7 +35,7 @@ func DialPlay(rawURL string) (*flv.Producer, error) {
 	return client.Producer()
 }
 
-func DialPublish(rawURL string) (io.Writer, error) {
+func DialPublish(rawURL string, cons *flv.Consumer) (io.Writer, error) {
 	u, err := url.Parse(rawURL)
 	if err != nil {
 		return nil, err
@@ -55,6 +55,11 @@ func DialPublish(rawURL string) (io.Writer, error) {
 		return nil, err
 	}
 
+	cons.FormatName = "rtmp"
+	cons.Protocol = "rtmp"
+	cons.RemoteAddr = conn.RemoteAddr().String()
+	cons.URL = rawURL
+
 	return client, nil
 }