{"action":"created","issue":{"url":"https://api.github.com/repos/Yelp/pyleus/issues/135","repository_url":"https://api.github.com/repos/Yelp/pyleus","labels_url":"https://api.github.com/repos/Yelp/pyleus/issues/135/labels{/name}","comments_url":"https://api.github.com/repos/Yelp/pyleus/issues/135/comments","events_url":"https://api.github.com/repos/Yelp/pyleus/issues/135/events","html_url":"https://github.com/Yelp/pyleus/pull/135","id":97583733,"number":135,"title":"add sleep_spout_wait_strategy_time_ms to topology config","user":{"login":"imcom","id":192839,"avatar_url":"https://avatars.githubusercontent.com/u/192839?v=3","gravatar_id":"","url":"https://api.github.com/users/imcom","html_url":"https://github.com/imcom","followers_url":"https://api.github.com/users/imcom/followers","following_url":"https://api.github.com/users/imcom/following{/other_user}","gists_url":"https://api.github.com/users/imcom/gists{/gist_id}","starred_url":"https://api.github.com/users/imcom/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/imcom/subscriptions","organizations_url":"https://api.github.com/users/imcom/orgs","repos_url":"https://api.github.com/users/imcom/repos","events_url":"https://api.github.com/users/imcom/events{/privacy}","received_events_url":"https://api.github.com/users/imcom/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/Yelp/pyleus/labels/feature","name":"feature","color":"fbca04"}],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":9,"created_at":"2015-07-28T00:12:45Z","updated_at":"2016-05-12T10:37:59Z","closed_at":"2015-09-22T11:20:28Z","pull_request":{"url":"https://api.github.com/repos/Yelp/pyleus/pulls/135","html_url":"https://github.com/Yelp/pyleus/pull/135","diff_url":"https://github.com/Yelp/pyleus/pull/135.diff","patch_url":"https://github.com/Yelp/pyleus/pull/135.patch"},"body":"sleep spout wait strategy time is quite useful when use kafka spout or similar. When the source queue is empty, we do not want storm cluster run into the crazy looping"},"comment":{"url":"https://api.github.com/repos/Yelp/pyleus/issues/comments/218721023","html_url":"https://github.com/Yelp/pyleus/pull/135#issuecomment-218721023","issue_url":"https://api.github.com/repos/Yelp/pyleus/issues/135","id":218721023,"user":{"login":"imcom","id":192839,"avatar_url":"https://avatars.githubusercontent.com/u/192839?v=3","gravatar_id":"","url":"https://api.github.com/users/imcom","html_url":"https://github.com/imcom","followers_url":"https://api.github.com/users/imcom/followers","following_url":"https://api.github.com/users/imcom/following{/other_user}","gists_url":"https://api.github.com/users/imcom/gists{/gist_id}","starred_url":"https://api.github.com/users/imcom/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/imcom/subscriptions","organizations_url":"https://api.github.com/users/imcom/orgs","repos_url":"https://api.github.com/users/imcom/repos","events_url":"https://api.github.com/users/imcom/events{/privacy}","received_events_url":"https://api.github.com/users/imcom/received_events","type":"User","site_admin":false},"created_at":"2016-05-12T10:37:59Z","updated_at":"2016-05-12T10:37:59Z","body":"@howardx you are on the right track, under spout options section you have `zk_hosts` property, this is where the Kafka lies. Kafka uses ZK for registration so when you set the topic, Storm will use that topic and the ZK servers to find corresponding Kafka brokers. The only problem is with Storm you can not separate Kafka with Storm, they have to share the same ZK cluster .. but with different (better) chroot"}}