{"action":"created","issue":{"url":"https://api.github.com/repos/doujiang24/lua-resty-kafka/issues/6","labels_url":"https://api.github.com/repos/doujiang24/lua-resty-kafka/issues/6/labels{/name}","comments_url":"https://api.github.com/repos/doujiang24/lua-resty-kafka/issues/6/comments","events_url":"https://api.github.com/repos/doujiang24/lua-resty-kafka/issues/6/events","html_url":"https://github.com/doujiang24/lua-resty-kafka/issues/6","id":59264830,"number":6,"title":"send err:not foundd topic","user":{"login":"lilbrianxp","id":11232991,"avatar_url":"https://avatars.githubusercontent.com/u/11232991?v=3","gravatar_id":"","url":"https://api.github.com/users/lilbrianxp","html_url":"https://github.com/lilbrianxp","followers_url":"https://api.github.com/users/lilbrianxp/followers","following_url":"https://api.github.com/users/lilbrianxp/following{/other_user}","gists_url":"https://api.github.com/users/lilbrianxp/gists{/gist_id}","starred_url":"https://api.github.com/users/lilbrianxp/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/lilbrianxp/subscriptions","organizations_url":"https://api.github.com/users/lilbrianxp/orgs","repos_url":"https://api.github.com/users/lilbrianxp/repos","events_url":"https://api.github.com/users/lilbrianxp/events{/privacy}","received_events_url":"https://api.github.com/users/lilbrianxp/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":9,"created_at":"2015-02-27T17:12:25Z","updated_at":"2015-06-09T02:13:47Z","closed_at":null,"body":"Hi,\r\n\r\nNot sure why I'm getting this error and the topic do exist. I also tested it through client python with the same topic and that worked.\r\n\r\n\r\n....\r\n....\r\n\r\n\r\nlocal broker_list = {\r\n             { host = \"127.0.0.1\", port = 9092 },\r\n         }\r\n\r\n \t\tlocal key = \"key1\"\r\n         local message = \"hello world\"\r\n         local p = producer:new(broker_list)\r\n\r\n         local offset, err = p:send(\"test\", key,message)\r\n         if not offset then\r\n             ngx.say(\"send err:\", err)\r\n             return\r\n         end\r\n         ngx.say(\"send success, offset: \", tostring(offset))\r\n\r\n\r\nUsing:\r\nOpenresty 1.7.2.1\r\nkafka server 2.10-0.8.2.0\r\n\r\nAlso, I tested on 0.8.1 and 0.8.1.1\r\nThanks,"},"comment":{"url":"https://api.github.com/repos/doujiang24/lua-resty-kafka/issues/comments/110198770","html_url":"https://github.com/doujiang24/lua-resty-kafka/issues/6#issuecomment-110198770","issue_url":"https://api.github.com/repos/doujiang24/lua-resty-kafka/issues/6","id":110198770,"user":{"login":"sunchenxian","id":12724715,"avatar_url":"https://avatars.githubusercontent.com/u/12724715?v=3","gravatar_id":"","url":"https://api.github.com/users/sunchenxian","html_url":"https://github.com/sunchenxian","followers_url":"https://api.github.com/users/sunchenxian/followers","following_url":"https://api.github.com/users/sunchenxian/following{/other_user}","gists_url":"https://api.github.com/users/sunchenxian/gists{/gist_id}","starred_url":"https://api.github.com/users/sunchenxian/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sunchenxian/subscriptions","organizations_url":"https://api.github.com/users/sunchenxian/orgs","repos_url":"https://api.github.com/users/sunchenxian/repos","events_url":"https://api.github.com/users/sunchenxian/events{/privacy}","received_events_url":"https://api.github.com/users/sunchenxian/received_events","type":"User","site_admin":false},"created_at":"2015-06-09T02:13:47Z","updated_at":"2015-06-09T02:13:47Z","body":"@doujiang24 \r\nHi,  there are some errors in  error log file：\r\n       \r\n         2015/06/09 10:08:18 [error] 31350#0: [lua] client.lua:150: _fetch_metadata(): all brokers failed in fetch topic metadata, context: ngx.timer, client: 127.0.0.1, server: 0.0.0.0:9100\r\n         2015/06/09 10:08:18 [error] 31350#0: [lua] client.lua:150: _fetch_metadata(): all brokers failed in fetch topic metadata, context: ngx.timer, client: 127.0.0.1, server: 0.0.0.0:9100\r\n         2015/06/09 10:08:18 [error] 31350#0: [lua] producer.lua:255: buffered messages send to kafka err: not foundd topic, retryable: true, topic: test, partition_id: -1, length: 1, context: ngx.timer, client: 127.0.0.1, server: 0.0.0.0:9100\r\n\r\nI will try a domain instead of localhost to verify your guess."}}