tweak kafka controller response message

Signed-off-by: neo <1100909+neowu@users.noreply.github.com>

Author: neowu

build.gradle.kts

@@ -7,7 +7,7 @@ apply(plugin = "project")
 
 subprojects {
     group = "core.framework"
-    version = "9.2.2"
+    version = "9.2.2-b0"
     repositories {
         maven {
             url = uri("https://neowu.github.io/maven-repo/")

core-ng/src/main/java/core/framework/internal/web/sys/KafkaController.java

@@ -46,7 +46,7 @@ public Response publish(Request request) {
         ProducerRecord<byte[], byte[]> record = record(topic, key, body, actionLog);
         producer.send(record);
 
-        return Response.text(Strings.format("message published, topic={}, key={}, message={}", topic, key, new String(body, UTF_8)));
+        return Response.text(Strings.format("message published, refId={}, topic={}, key={}, message={}", actionLog.id, topic, key, new String(body, UTF_8)));
     }
 
     public Response handle(Request request) throws Exception {
@@ -73,7 +73,7 @@ public Response handle(Request request) throws Exception {
         } else {
             throw new Error("handler not found, topic=" + topic);
         }
-        return Response.text(Strings.format("message handled, topic={}, key={}, message={}", topic, key, new String(body, UTF_8)));
+        return Response.text(Strings.format("message handled, id={}, topic={}, key={}, message={}", actionLog.id, topic, key, new String(body, UTF_8)));
     }
 
     private Object message(String topic, String key, byte[] body, MessageProcess<Object> process, ActionLog actionLog) throws IOException {