{"action":"created","issue":{"url":"https://api.github.com/repos/danieljoos/libkafka-asio/issues/7","labels_url":"https://api.github.com/repos/danieljoos/libkafka-asio/issues/7/labels{/name}","comments_url":"https://api.github.com/repos/danieljoos/libkafka-asio/issues/7/comments","events_url":"https://api.github.com/repos/danieljoos/libkafka-asio/issues/7/events","html_url":"https://github.com/danieljoos/libkafka-asio/issues/7","id":96581136,"number":7,"title":"[Client] sending requests pretty frequent results in error \"Another operation is still in progress\"","user":{"login":"DEvil0000","id":3344302,"avatar_url":"https://avatars.githubusercontent.com/u/3344302?v=3","gravatar_id":"","url":"https://api.github.com/users/DEvil0000","html_url":"https://github.com/DEvil0000","followers_url":"https://api.github.com/users/DEvil0000/followers","following_url":"https://api.github.com/users/DEvil0000/following{/other_user}","gists_url":"https://api.github.com/users/DEvil0000/gists{/gist_id}","starred_url":"https://api.github.com/users/DEvil0000/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/DEvil0000/subscriptions","organizations_url":"https://api.github.com/users/DEvil0000/orgs","repos_url":"https://api.github.com/users/DEvil0000/repos","events_url":"https://api.github.com/users/DEvil0000/events{/privacy}","received_events_url":"https://api.github.com/users/DEvil0000/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/danieljoos/libkafka-asio/labels/enhancement","name":"enhancement","color":"84b6eb"}],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":35,"created_at":"2015-07-22T14:24:54Z","updated_at":"2015-08-04T08:09:09Z","closed_at":null,"body":"I was trying to send `MessageSets` with 1000 `Messages` at a high rate. This is why I was running into this.\r\nIt seams the `Client` return with a error in the callback because it is in `kStateWriting`. Callback triggered in `AsyncRequest`.\r\nI would not expect a callback for this case - I would expect a return value indicating this.\r\nOr more correct I would expect a `Client` where I can send more than one request at a time (or queue them?). I don't like to care about Client states and being busy.\r\n\r\nSuch a MessageSet takes about 10 to 20 ms until I can use the Client again. Compared to the faked rdkafak performance this is pretty slow.\r\n\r\nI guess it is somehow `Network`/`Socket`/`Connection`/`Buffer` related.\r\nShould it open more Connections to the Broker?"},"comment":{"url":"https://api.github.com/repos/danieljoos/libkafka-asio/issues/comments/127514658","html_url":"https://github.com/danieljoos/libkafka-asio/issues/7#issuecomment-127514658","issue_url":"https://api.github.com/repos/danieljoos/libkafka-asio/issues/7","id":127514658,"user":{"login":"DEvil0000","id":3344302,"avatar_url":"https://avatars.githubusercontent.com/u/3344302?v=3","gravatar_id":"","url":"https://api.github.com/users/DEvil0000","html_url":"https://github.com/DEvil0000","followers_url":"https://api.github.com/users/DEvil0000/followers","following_url":"https://api.github.com/users/DEvil0000/following{/other_user}","gists_url":"https://api.github.com/users/DEvil0000/gists{/gist_id}","starred_url":"https://api.github.com/users/DEvil0000/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/DEvil0000/subscriptions","organizations_url":"https://api.github.com/users/DEvil0000/orgs","repos_url":"https://api.github.com/users/DEvil0000/repos","events_url":"https://api.github.com/users/DEvil0000/events{/privacy}","received_events_url":"https://api.github.com/users/DEvil0000/received_events","type":"User","site_admin":false},"created_at":"2015-08-04T08:09:09Z","updated_at":"2015-08-04T08:09:09Z","body":">I wouldn't discard all pending responses on every possible error. Maybe only on the connection related ones?\r\n\r\nTrue, sorry this was what I meant.\r\n>In case we don't need an auto connect for responses, we can also get rid of the EnqueueConnectionHandler and is connecting? part, as we can only reach that part from the write side.\r\n\r\nTrue"}}