charlesdong1991 commented on code in PR #399:
URL: https://github.com/apache/fluss-rust/pull/399#discussion_r2935124756
##########
crates/fluss/src/rpc/server_connection.rs:
##########
@@ -301,9 +325,9 @@ where
match map.remove(&header.request_id) {
Some(active_request) => active_request,
_ => {
- log::warn!(
+ log::debug!(
Review Comment:
thanks for response @luoyuxia
i checked Kafka client, it seems Kafka closes connection on timeout, so IIUC
late responses can never arrive, aka, Kafka ignores response for request after
timeout.
But it seems it treats as `info` level:
```
log.info("Disconnecting from node {} due to request timeout.",
nodeId);
```
so i think here i will switch to `warn` level then! 🙏
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
