topic

src/socket/protocol/variable/publish.rs

@@ -19,7 +19,7 @@ impl PublishHeader {
     pub fn new(topic: impl AsRef<str>, key: Option<impl AsRef<str>>, payload_type: PayloadType, message_id: i64, business_type: i32) -> Self {
         Self { 
             topic: topic.as_ref().to_string(),
-            ack_topic: "_ack/socket-center-message".to_string(),
+            ack_topic: topic.as_ref().to_string(),
             routing_key: key.map(|s| s.as_ref().to_string()),
             payload_type,
             message_id,