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 '{
    "userId": "string"
}'

返回响应

🟢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）删除专题信息

Java客户调用接口生成签名工具类