文档中心

日志服务

请输入

Kafka 协议消费

OpenKafkaConsumer

调用 OpenKafkaConsumer 接口为指定日志主题开启 Kafka 协议消费功能。

使用说明

调用此接口为日志主题开启 Kafka 协议消费功能之后，可以将日志主题作为 Kafka 的 Topic 进行消费，每条日志对应一条 Kafka 消息。通过 Kafka 协议消费日志具体方式和配置请参考通过 Kafka 协议消费日志。

此接口调用频率限制为 20 次/s，超出频率限制会报错 ExceedQPSLimit。

说明

请求说明

请求参数

下表仅列出该接口特有的请求参数和部分公共参数。更多信息请见公共参数。

Body

参数	类型	是否必选	示例值	描述
TopicId	String	是	0fdaa6b6-3c9f-424c-8664-fc0d222c****	日志主题的 ID。

返回参数

本接口无特有的返回参数。更多信息请见返回结构。

请求示例

返回示例

错误码

下表为您列举了该接口与业务逻辑相关的错误码。公共错误码请参见公共错误码文档。

HTTP 状态码	错误码	错误信息	说明
400	InvalidArgument	Invalid argument key %s, value %s, please check argument.	参数不合法。
404	TopicNotExist	topic %s does not exist.	日志主题不存在。
400	ConsumeTopicOperateDisable	Please try this operator for consume topic after 2min.	请勿频繁操作，请于 2 分钟后再进行。
500	InternalServerError	We encountered an unexpected server error, please try again later.	服务器内部错误。

最近更新时间：2025.10.14 14:20:53

这个页面对您有帮助吗？

有用

无用