kafka-logger

    它可以将接口请求日志以 JSON 的形式推送给外部 Kafka 集群。如果在短时间内没有收到日志数据，请放心，它会在我们的批处理处理器中的计时器功能到期后自动发送日志。

    有关 Apache APISIX 中 Batch-Processor 的更多信息，请参考。 Batch-Processor

    属性

    • origin:

      1.   GET /hello?ab=cd HTTP/1.1
      2.   host: localhost
      3.   content-length: 6
      4.   connection: close

    消息将首先写入缓冲区。 当缓冲区超过batch_max_size时，它将发送到 kafka 服务器， 或每个buffer_duration刷新缓冲区。

    Broker 列表

    插件支持一次推送到多个 Broker，如下配置：

    如何启用

    1. 为特定路由启用 kafka-logger 插件。
    2. {
    3.     "plugins": {
    4.        "kafka-logger": {
    5.            "broker_list" :
    6.              {
    7.                "127.0.0.1":9092
    8.              },
    9.            "kafka_topic" : "test2",
    10.            "key" : "key1"
    11.        }
    12.     },
    13.     "upstream": {
    14.        "nodes": {
    15.        },
    17.     },
    18.     "uri": "/hello"
    19. }'

    成功

    禁用插件

    1. $ curl http://127.0.0.1:2379/apisix/admin/routes/1  -H 'X-API-KEY: edd1c9f034335f136f87ad84b625c8f1' -X PUT -d value='
    2. {
    3.     "methods": ["GET"],
    4.     "uri": "/hello",
    5.     "plugins": {},
    6.     "upstream": {
    7.         "type": "roundrobin",
    8.         "nodes": {
    9.             "127.0.0.1:1980": 1
    10.         }