From f5191248b5df43ee6942b70c2b925af7a463c252 Mon Sep 17 00:00:00 2001
From: "xiang.zhou" <xiang.zhou@emqx.io>
Date: Wed, 19 Nov 2025 10:26:56 +0800
Subject: [PATCH] ekuiper:add log

---
 plugins/ekuiper/read_write.c | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/plugins/ekuiper/read_write.c b/plugins/ekuiper/read_write.c
index 821c7685..1d5baadd 100644
--- a/plugins/ekuiper/read_write.c
+++ b/plugins/ekuiper/read_write.c
@@ -234,9 +234,17 @@ void recv_data_callback(void *arg)
     if (req->singular) {
         rv = send_write_tag_req(plugin, &req->single, json_str, trace_flag,
                                 trace_id, span_id);
+        if (rv == 0) {
+            plog_notice(plugin, "write tag %s.%s on node %s", req->single.group,
+                        req->single.tag, req->single.node);
+        }
     } else {
         rv = send_write_tags_req(plugin, &req->plural, json_str, trace_flag,
                                  trace_id, span_id);
+        if (rv == 0) {
+            plog_notice(plugin, "write %d tags on node %s", req->plural.n_tag,
+                        req->plural.node);
+        }
     }
 
     if (0 != rv) {