gaoxingliang commented on issue #10359:
URL: https://github.com/apache/apisix/issues/10359#issuecomment-1820504886
This issue persist.
The apisix version is 3.6.0.
and the conf:
```
{
"_meta": {
"disable": false
},
"brokers": [
{
"host": "192.168.102.227",
"port": 39091
}
],
"include_req_body": true,
"kafka_topic": "apisix-log-test",
"name": "apisix-kafkalogger"
}
```
and the error log:
```
2023/11/21 09:02:25 [warn] 55#55: *1345942 [lua] plugins.lua:54: query
parameter "all" will be deprecated soon., client: 10.233.113.84, server: ,
request: "GET /apisix/admin/plugins?all=true HTTP/1.1", host:
"apisix-admin.apisix.svc.cluster.local:9180"
2023/11/21 09:02:28 [error] 57#57: *1350184 [lua] batch-processor.lua:95:
Batch Processor[apisix-kafkalogger] failed to process entries: failed to send
data to Kafka topic: not found broker, brokers: null, context: ngx.timer,
client: 10.233.107.0, server: 0.0.0.0:9080
2023/11/21 09:02:28 [error] 57#57: *1350184 [lua] batch-processor.lua:104:
Batch Processor[apisix-kafkalogger] exceeded the max_retry_count[1] dropping
the entries, context: ngx.timer, client: 10.233.107.0, server: 0.0.0.0:9080
```
I don't know why it said the not found broker. I telnet the kafka and it's
connected.
I found the kafka logger plugin code error msg use the deprecated
`broker_list`. so I also try with the conf:
```
"broker_list": {
"192.168.102.227": 39091
},
```
It also says the broker list is null. I think the problem is: the conf get
from etcd or somewhere is NULL.
the source code is here:
https://github.com/apache/apisix/blob/master/apisix/plugins/kafka-logger.lua#L203
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
