spacewander commented on issue #3060: URL: https://github.com/apache/apisix/issues/3060#issuecomment-747393019
At least we know the correct topic is sent. The topic-partition relation is maintained inside lua-resty-kafka, the kafka client used by APISIX. Since the problem may happen after sending topic and before returning from https://github.com/apache/apisix/blob/f476d2c3dc68439406a9531fc8b4a2a2d50c1333/apisix/plugins/kafka-logger.lua#L95-L100, I think you need to add log inside lua-resty-kafka, and see what happened inside. You can start from https://github.com/doujiang24/lua-resty-kafka/blob/dba4dc13a3e00a587a7b206945bc07ab6ec52345/lib/resty/kafka/client.lua#L144 I will be busy in the coming few days, so I may not reply you for several days. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
