edib commented on issue #12804: URL: https://github.com/apache/apisix/issues/12804#issuecomment-3636181144
in kubernetes, I have used following helm. https://apache.github.io/apisix-helm-chart/docs/en/latest/apisix.html Routes etc. are clearly working. I have created a httpbin service. It works too. Then I add the following code as kafka-logger. ``` { "kafka_topic": "test", "name": "kafka logger", "brokers": [ { "port": 9092, "host": "kafka-kafka-node-pool-0.kafka-kafka-brokers.apisix.svc" } ], "producer_type": "async", "key": "key1", "batch_max_size": 5 } ``` 2025/12/10 09:32:56 [error] 56#56: *1128725 [lua] client.lua:210: _fetch_metadata(): all brokers failed in fetch topic metadata, context: ngx.timer, client: 10.233.102.128, server: 0.0.0.0:908 2025/12/10 09:26:53 [error] 70#70: *1085195 [lua] batch-processor.lua:96: Batch Processor[kafkalogger] failed to process entries: failed to send data to Kafka topic: closed, brokers: null, context: ngx.timer, client: 10.233.102.128, server: 0.0.0.0:9080 2025/12/10 09:26:53 [error] 70#70: *1085195 [lua] batch-processor.lua:106: Batch Processor[kafkalogger] exceeded the max_retry_count[1] dropping the entries, context: ngx.timer, client: 10.233.102.128, server: 0.0.0.0:9080 these are the logs. this is the strimzi kafka installation. single node and no auth for the test purposes. it is in the same namespace. I have also tested via a kafka-ui and kafka-console-producer.sh. the kafka is working. -- 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]
