fix code

mxsm · mxsm · commit 1556673e4572 · 2024-10-27T23:58:27.000+08:00
diff --git a/rocketmq-namesrv/src/processor/default_request_processor.rs b/rocketmq-namesrv/src/processor/default_request_processor.rs
@@ -288,7 +288,7 @@ impl DefaultRequestProcessor {
                 .write()
                 .get_kv_list_by_namespace("ORDER_TOPIC_CONFIG")
             {
-                response_command = response_command.set_body(Bytes::from(value));
+                response_command = response_command.set_body(value);
             }
         }
         let register_broker_result = result.unwrap();

Original file line number	Diff line number	Diff line change
`@@ -288,7 +288,7 @@ impl DefaultRequestProcessor {`
`288`	`288`	`.write()`
`289`	`289`	`.get_kv_list_by_namespace("ORDER_TOPIC_CONFIG")`
`290`	`290`	`{`
`291`		`- response_command = response_command.set_body(Bytes::from(value));`
	`291`	`+ response_command = response_command.set_body(value);`
`292`	`292`	`}`
`293`	`293`	`}`
`294`	`294`	`let register_broker_result = result.unwrap();`