bug: when I use the kafka-logger plugin, failed to fetch the time in kafka

[lihuawei321]

Issue description

我写入kafka的日志格式是：
[{"client_ip":"192.168.35.122","host":"192.168.9.234","@timestamp":"2021-12-07T10:41:12+08:00","route_id":"363894265081758809"}]
但是kafka显示的没有时间戳

Environment

• apisix version (cmd: apisix version): 2.10
• OS (cmd: uname -a): centos7
• OpenResty / Nginx version (cmd: nginx -V or openresty -V):
• etcd version, if have (cmd: run curl http://127.0.0.1:9090/v1/server_info to get the info from server-info API):
• apisix-dashboard version, if have: 2.9
• the plugin runner version, if the issue is about a plugin runner (cmd: depended on the kind of runner):
• luarocks version, if the issue is about installation (cmd: luarocks --version):

[juzhiyuan]

Hi, could you please provide more steps so I could reproduce it?

[tzssangglass]

pls describe it more clearly. From the information you have provided, I do not know what is failed to fetch the time in kafka

[github-actions]

This issue has been marked as stale due to 350 days of inactivity. It will be closed in 2 weeks if no further activity occurs. If this issue is still relevant, please simply write any comment. Even if closed, you can still revive the issue at any time or discuss it on the dev@apisix.apache.org list. Thank you for your contributions.

[github-actions]

This issue has been closed due to lack of activity. If you think that is incorrect, or the issue requires additional review, you can revive the issue at any time.

[mrostamii]

I also have the same issue, the created service config is:

{
    "upstream_id": "test-case",
    "name": "test-case",
    "plugins": {
        "kafka-logger": {
            "brokers": [
                {
                    "host": "1.50.0.10",
                    "port": 9092
                },
                {
                    "host": "1.50.0.11",
                    "port": 9092
                },
                {
                    "host": "1.50.0.12",
                    "port": 9092
                }
            ],
            "name": "kafka logger",
            "kafka_topic": "apisix",
            "key": "test-case",
            "batch_max_size": 100,
            "timeout": 3,
            "timestamp": true,
            "log_format": {
                "timestamp": "$time_iso8601",
                "consumer": "$consumer_name",
                "service_id": "$service_id",
                "route_id": "$route_id",
                "request_id": "$request_id",
                "latency": "$request_time",
                "node_hostname": "$hostname",
                "window_start_time": "$time_unix"
            }
        },
        "key-auth": {},
        "cors": {
            "allow_origins": "*",
            "allow_methods": "*",
            "allow_headers": "*",
            "expose_headers": "*"
        },
        "response-rewrite": {
            "headers": {
                "X-Server-IP": "$remote_addr",
                "X-Real-IP": "$http_x_real_ip",
                "X-Forwarded-For": "$http_x_forwarded_for",
                "X-Request-ID": "$request_id",
                "X-Original-URI": "$uri",
                "X-Upstream-IP": "$upstream_addr",
                "X-Upstream-Response-Time": "$upstream_response_time",
                "X-Upstream-Status": "$upstream_status",
                "X-CF-Ray": "$http_cf_ray",
                "X-CF-IPCountry": "$http_cf_ipcountry",
                "X-CF-Connecting-IP": "$http_cf_connecting_ip",
                "X-CF-Visitor": "$http_cf_visitor",
                "X-CF-Request-ID": "$http_cf_request_id",
                "X-APISIX-Upstream-Status": "$upstream_status",
                "X-APISIX-Proxy-Latency": "$upstream_response_time",
                "X-APISIX-Server": "$hostname",
                "X-APISIX-Route-ID": "$route_id",
                "X-APISIX-Consumer-Name": "$consumer_name",
                "X-SSL-Protocol": "$ssl_protocol",
                "X-SSL-Cipher": "$ssl_cipher",
                "X-Scheme": "$scheme",
                "X-Request-Time": "$request_time",
                "X-APISIX-Upstream-Filter-Time": "$upstream_filter_time",
                "X-First-Byte-Time": "$first_byte_time"
            }
        }
    }
}

Version:

apisix: 3.11.0
kafka: 7.4.0

[bfyxzls]

I also have the same issue, the created service config is:

"log_format": {
    "@timestamp": "$time_iso8601",
    "accessPage": "$http_accessPage",
    "accessSource": "$http_accessSource",
    "api": "$request_uri",
    "appVersion": "$http_appVersion"
  }