kafka测试发送消息 Copy

开发中

POST

/front/kafka/send-with-metering

请求参数

Query 参数

Header 参数

Body 参数application/json

示例

{
  "id": 1,
  "task_id": "task-12345",
  "user_id": "93fa6911fc2f4b6ebcb891d4a9b356d6",
  "api_key": "sk-prod-a7MQQOEQb5P1xZXj",
  "model_name": "Qwen-7B",
  "instance_id": "instance-abcde",
  "status": "completed",
  "failure_reason": "",
  "created_at": "2025-09-12T10:00:58.278434",
  "dequeued_at": "2025-09-12T10:00:58.553470",
  "completed_at": "2025-09-12T10:00:59.454931",
  "wait_duration_ms": 27115,
  "processing_duration_ms": 901111,
  "task_type": "API"
}

请求示例代码

Shell

JavaScript

Java

Swift

PHP

Python

HTTP

Objective-C

Ruby

OCaml

Dart

curl --location --request POST '/front/kafka/send-with-metering?topic=11&message=22' \
--header 'FrontToken: {{FrontToken}}' \
--header 'Content-Type: application/json' \
--data-raw '{
  "id": 1,
  "task_id": "task-12345",
  "user_id": "93fa6911fc2f4b6ebcb891d4a9b356d6",
  "api_key": "sk-prod-a7MQQOEQb5P1xZXj",
  "model_name": "Qwen-7B",
  "instance_id": "instance-abcde",
  "status": "completed",
  "failure_reason": "",
  "created_at": "2025-09-12T10:00:58.278434",
  "dequeued_at": "2025-09-12T10:00:58.553470",
  "completed_at": "2025-09-12T10:00:59.454931",
  "wait_duration_ms": 27115,
  "processing_duration_ms": 901111,
  "task_type": "API"
}'

返回响应

🟢200成功

application/json

Body

示例

{
    "code": 0,
    "message": "string"
}

修改于 2025-11-08 16:16:49

kafka测试发送消息

获取redis中的小时戳对象