跳到主要内容
版本:1.1-beta

Kafka日志

收集请求网关的日志信息,并将其输出到Kafka中,方便使用者进行二次操作,如日志分析等。

特性

能够将程序运行中产生的日志内容输出到指定Kafka集群队列中。

操作演示

新建Kafka日志配置

  1. 点击左侧导航栏运维与集成 -> 日志配置 -> Kafka日志,点击添加Kafka日志

  1. 填写Kafka日志配置。

配置说明

字段名称说明
版本Kafka版本
服务器地址Kafka服务地址,多个地址用英文逗号分隔
TopicKafka服务Topic信息
Partition Typepartition的选择方式,默认采用hash,选择hash时,若partition_key为空,则采用随机选择random
PartitionPartition Type为manual时,该项指定分区号
Partition KeyPartition Type为hash时,该项指定hash值
请求超时时间超时时间,单位为second
输出格式输出日志内容格式,支持单行、Json格式输出
格式化配置输出格式模版,配置教程点此进行跳转

示例格式化配置

{
"fields": [
"$time_iso8601",
"$request_id",
"@request",
"@proxy",
"@response",
"@status_code",
"@time"
],
"request": [
"$request_method",
"$scheme",
"$request_uri",
"$host",
"$header",
"$remote_addr"
],
"proxy": [
"$proxy_method",
"$proxy_scheme",
"$proxy_uri",
"$proxy_host",
"$proxy_header",
"$proxy_addr"
],
"response": [
"$response_header"
],
"status_code": [
"$status",
"$proxy_status"
],
"time": [
"$request_time",
"$response_time"
]
}

3、点击提交后,Kafka日志配置添加完成

上线

  1. 点击待上线配置后方的上线按钮。