io log

main.go

@@ -1197,9 +1197,16 @@ func ApiOrJWT(c *fiber.Ctx) error {
 	msgToKafkaAttributes := []slog.Attr{
 		slog.String("TaskId", pbMsg.TaskId),
 		slog.Uint64("TaskType", pbMsg.TaskType),
-		slog.Int("TaskType", int(pbMsg.TaskKind)),
+		slog.Int("TaskKind", int(pbMsg.TaskKind)),
 		slog.String("TaskCmd", pbMsg.TaskCmd),
 		slog.String("TaskParam", string(pbMsg.TaskParam)),
+		slog.String("TaskTimestamp", string(pbMsg.TaskTimestamp)),
+		slog.String("TaskCallback", pbMsg.TaskCallback),
+		slog.String("TaskUid", pbMsg.TaskUid),
+		slog.String("TaskFee", pbMsg.TaskFee),
+		slog.Int("TaskInLen", int(pbMsg.TaskInLen)),
+		slog.Int64("TaskWorkload", pbMsg.TaskWorkload),
+		slog.Int("ContainerPubkey Len", len(pbMsg.ContainerPubkey)),
 	}
 
 	kafkaattributes := append(