tencent cloud

文档反馈

获取投递配置

最后更新时间:2022-02-22 09:53:51

    功能描述

    本接口用于修改现有的投递任务。

    请求

    请求行

    PUT /consumer
    

    请求示例

    PUT /shipper?topic_id=xxxxxxxx HTTP/1.1
    Host: <Region>.cls.myqcloud.com
    Authorization: <AuthorizationString>
    Content-Type: application/json
    {
    "effective": true,
    "ckafka": {
      "vip": "10.123.123.123",
      "vport": "8888",
      "instance_id": "xxxxxx",
      "instance_name": "myname",
      "topic_id": "xxxxx",
      "topic_name": "xxx",
      
    },
    "content": {"enable_tag":true,"meta_fields":["__SOURCE__"]},
    "need_content": true
    }
    

    请求头

    无特殊。

    请求参数

    字段名 类型 位置 是否必有 含义
    topic_id string query 投递任务绑定的 topic_id
    effective bool body 投递任务是否生效
    ckafka object body Ckafka 实例的信息
    content object body Ckafka 的元数据信息
    need_content bool body 是否投递 Ckafka 的元数据信息,默认为 true

    ckafka 格式如下:

    字段名 类型 是否必有 含义
    vip string Ckafka 的 vip
    vport string Ckafka 的 vport
    instance_id string Ckafka 的 instance_id
    instance_name string Ckafka 的 instance_name
    topic_id string Ckafka 的 topic_id
    topic_name string Ckafka 的 topic_name

    content 格式如下:

    字段名 类型 是否必有 含义
    enable_tag bool 是否投递 TAG 信息
    meta_fields array(string) 需要投递的元数据列表,目前仅支持:__SOURCE__,__FILENAME__和__TIMESTAMP__

    其中 effective、ckafka 和 content 至少要有一个。

    响应

    响应示例

    HTTP/1.1 200 OK
    Content-Type: application/json
    Content-Length: 0
    

    响应头

    无特殊。

    响应参数

    无。

    错误码

    参见 错误码

    联系我们

    联系我们,为您的业务提供专属服务。

    技术支持

    如果你想寻求进一步的帮助,通过工单与我们进行联络。我们提供7x24的工单服务。

    7x24 电话支持