diff --git a/src/connection/connection.c b/src/connection/connection.c
index 820577da..f652edcc 100644
--- a/src/connection/connection.c
+++ b/src/connection/connection.c
@@ -447,11 +447,21 @@ ssize_t neu_conn_recv(neu_conn_t *conn, uint8_t *buf, ssize_t len)
                 conn->fd, len, ret, strerror(errno), errno);
             conn_disconnect(conn);
         }
+    } else if (conn->param.type == NEU_CONN_UDP ||
+               conn->param.type == NEU_CONN_UDP_TO) {
+        if (ret <= 0) {
+            zlog_error(
+                conn->param.log,
+                "udp conn fd: %d, recv buf len %zd, ret: %zd, errno: %s(%d)",
+                conn->fd, len, ret, strerror(errno), errno);
+            conn_disconnect(conn);
+        }
     } else {
         if (ret <= 0) {
-            zlog_error(conn->param.log,
-                       "conn fd: %d, recv buf len %zd, ret: %zd, errno: %s(%d)",
-                       conn->fd, len, ret, strerror(errno), errno);
+            zlog_error(
+                conn->param.log,
+                "tcp conn fd: %d, recv buf len %zd, ret: %zd, errno: %s(%d)",
+                conn->fd, len, ret, strerror(errno), errno);
             if (ret == 0 || (ret == -1 && errno != EAGAIN)) {
                 conn_disconnect(conn);
             }