doujiang24 / lua-resty-kafka

Lua kafka client driver for the Openresty based on the cosocket API
BSD 3-Clause "New" or "Revised" License
801 stars 274 forks source link

send() failed (104: Connection reset by peer), context: ngx.timer, client: 10.150.50.235, server: 0.0.0.0:80 #67

Open sstong123 opened 6 years ago

sstong123 commented 6 years ago

My kafka is active,and I can telnet the kafka server from nginx server,and the topic is exist,but I got the error messge below when I post message from nginx to kafka in nginx's error.log: 2018/05/22 20:23:31 [error] 4698#0: send() failed (104: Connection reset by peer), context: ngx.timer, client: 10.150.50.235, server: 0.0.0.0:80 2018/05/22 20:23:31 [error] 4698#0: [lua] producer.lua:258: buffered messages send to kafka err: connection reset by peer, retryable: true, topic: pub_visit_topic_event, partition_id: 0, length: 89, context: ngx.timer, client: 10.150.50.235, server: 0.0.0.0:80

wuxin commented 5 years ago

We have same problem. When send signal kill -USR1 to split logs, we found that the Kafka producer will report timeout: 2018/08/23 15:01:41 [error] 14003#0: *158596703 [lua] producer.lua:258: buffered messages send to kafka err: timeout, retryable: nil, topic: topic_all, partition_id: 0, length: 31, context: ngx.timer, client: 10.153.203.167, server: 0.0.0.0:80

strive1216 commented 4 years ago

2019/11/20 16:55:04 [error] 16751#0: 29420802 lua tcp socket read timed out, context: ngx.timer, client: 10.151.76.253, server: 0.0.0.0:80 2019/11/20 16:55:04 [error] 16751#0: 29420802 [lua] producer.lua:272: buffered messages send to kafka err: timeout, retryable: nil, topic: data, partition_id: 0, length: 200, context: ngx.timer, client: 10.151.76.253, server: 0.0.0.0:80

我也遇到了这个问题 有什么办法解决没