{"action":"created","issue":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/242","labels_url":"https://api.github.com/repos/edenhill/librdkafka/issues/242/labels{/name}","comments_url":"https://api.github.com/repos/edenhill/librdkafka/issues/242/comments","events_url":"https://api.github.com/repos/edenhill/librdkafka/issues/242/events","html_url":"https://github.com/edenhill/librdkafka/issues/242","id":68228628,"number":242,"title":"Delivery Report Callback Queue","user":{"login":"jarreds","id":1414175,"avatar_url":"https://avatars.githubusercontent.com/u/1414175?v=3","gravatar_id":"","url":"https://api.github.com/users/jarreds","html_url":"https://github.com/jarreds","followers_url":"https://api.github.com/users/jarreds/followers","following_url":"https://api.github.com/users/jarreds/following{/other_user}","gists_url":"https://api.github.com/users/jarreds/gists{/gist_id}","starred_url":"https://api.github.com/users/jarreds/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/jarreds/subscriptions","organizations_url":"https://api.github.com/users/jarreds/orgs","repos_url":"https://api.github.com/users/jarreds/repos","events_url":"https://api.github.com/users/jarreds/events{/privacy}","received_events_url":"https://api.github.com/users/jarreds/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/edenhill/librdkafka/labels/discussion","name":"discussion","color":"01c0c0"},{"url":"https://api.github.com/repos/edenhill/librdkafka/labels/producer","name":"producer","color":"5319e7"}],"state":"closed","locked":false,"assignee":{"login":"edenhill","id":524990,"avatar_url":"https://avatars.githubusercontent.com/u/524990?v=3","gravatar_id":"","url":"https://api.github.com/users/edenhill","html_url":"https://github.com/edenhill","followers_url":"https://api.github.com/users/edenhill/followers","following_url":"https://api.github.com/users/edenhill/following{/other_user}","gists_url":"https://api.github.com/users/edenhill/gists{/gist_id}","starred_url":"https://api.github.com/users/edenhill/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/edenhill/subscriptions","organizations_url":"https://api.github.com/users/edenhill/orgs","repos_url":"https://api.github.com/users/edenhill/repos","events_url":"https://api.github.com/users/edenhill/events{/privacy}","received_events_url":"https://api.github.com/users/edenhill/received_events","type":"User","site_admin":false},"milestone":null,"comments":7,"created_at":"2015-04-14T00:42:26Z","updated_at":"2015-08-27T19:17:01Z","closed_at":"2015-08-27T19:17:01Z","body":"I noticed that delivery reports are called by popping messages off of a queue [here](https://github.com/edenhill/librdkafka/blob/master/src/rdkafka.c#L1664-L1702).\r\n\r\nThe application I'm building needs to insert checkpoint entries with the producer interspersed among the actual messages. I do not want to checkpoint after every message successfully produced. I can implement this in a number of ways, but...\r\n\r\nIt would be ideal if I could obtain info related to this dr callback queue, or at least know that another callback is going to be invoked without a call to ```rd_kafka_poll```. In that case, I would hold off on checkpointing until I knew that the delivery report callback queue is drained. Perhaps there is another mechanism to do this that I haven't discovered. Your feedback would be great.\r\n\r\n*An even crazier request that should be another issue... it would be amazing if there were a file descriptor on the delivery callbacks so I could do io multiplexing via ```select``` with some other network sockets the app waits on.*\r\n\r\nThank you"},"comment":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/comments/135527981","html_url":"https://github.com/edenhill/librdkafka/issues/242#issuecomment-135527981","issue_url":"https://api.github.com/repos/edenhill/librdkafka/issues/242","id":135527981,"user":{"login":"edenhill","id":524990,"avatar_url":"https://avatars.githubusercontent.com/u/524990?v=3","gravatar_id":"","url":"https://api.github.com/users/edenhill","html_url":"https://github.com/edenhill","followers_url":"https://api.github.com/users/edenhill/followers","following_url":"https://api.github.com/users/edenhill/following{/other_user}","gists_url":"https://api.github.com/users/edenhill/gists{/gist_id}","starred_url":"https://api.github.com/users/edenhill/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/edenhill/subscriptions","organizations_url":"https://api.github.com/users/edenhill/orgs","repos_url":"https://api.github.com/users/edenhill/repos","events_url":"https://api.github.com/users/edenhill/events{/privacy}","received_events_url":"https://api.github.com/users/edenhill/received_events","type":"User","site_admin":false},"created_at":"2015-08-27T19:17:01Z","updated_at":"2015-08-27T19:17:01Z","body":"See #204"}}