6）根据用户ID获取Kafka信息

POST

/v1/push/getKafkaInfo

3、数据推送相关接口

获取topic和组id信息(如果不存在就创建)

请求参数

Header 参数

appKey

AppKey

必需

nonce

随机数

必需

timestamp

时间戳

必需

signature

必需

签名，详见附件客户签名生成工具类

Body 参数application/json

根据用户ID获取Kafka信息入参

userId

string

用户id

必需

示例

{
  "userId": "string"
}

示例代码

Shell

JavaScript

Java

Swift

PHP

Python

HTTP

Objective-C

Ruby

OCaml

Dart

curl --location --request POST '/v1/push/getKafkaInfo' \
--header 'appKey;' \
--header 'nonce;' \
--header 'timestamp;' \
--header 'signature;' \
--header 'Content-Type: application/json' \
--data-raw ''

返回响应

🟢200OK

application/json

Body

返回数据格式

code

integer <int32>

可选

响应码【200代表成功,其他参见错误码值表】)

success

boolean

可选

是否成功【true代表成功,false代表失败】

message

string

响应消息

可选

data

object (KafkaInfoVO)

可选

Kafka信息结果集

topicName

string

topic名称

可选

consumerGroupId

string

消费者组ID

可选

errors

array[string]

错误信息集合

可选

time

string <date-time>

响应时间

可选

示例

{
  "code": 0,
  "success": true,
  "message": "string",
  "data": {
    "topicName": "string",
    "consumerGroupId": "string"
  },
  "errors": [
    "string"
  ],
  "time": "2019-08-24T14:15:22Z"
}

修改于 2024-08-15 09:52:06

5）删除专题信息

各个渠道参数校验/接口QPS等规则说明