We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5a9e829 commit e07791cCopy full SHA for e07791c
rocketmq-namesrv/src/processor/default_request_processor.rs
@@ -63,7 +63,7 @@ use rocketmq_remoting::{
63
},
64
runtime::processor::RequestProcessor,
65
};
66
-use tracing::warn;
+use tracing::{info, warn};
67
68
use crate::{route::route_info_manager::RouteInfoManager, KVConfigManager};
69
@@ -81,6 +81,11 @@ impl RequestProcessor for DefaultRequestProcessor {
81
) -> RemotingCommand {
82
let code = request.code();
83
let broker_request_code = RequestCode::value_of(code);
84
+ info!(
85
+ "Received request code:{}-{:?}",
86
+ code,
87
+ broker_request_code.as_ref()
88
+ );
89
match broker_request_code {
90
Some(RequestCode::PutKvConfig) => self.put_kv_config(request),
91
Some(RequestCode::GetKvConfig) => self.get_kv_config(request),
0 commit comments