跳到主要内容
版本：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. 点击待上线配置后方的上线按钮。