擅长:python、mysql、java
<p>使用iter_timeout参数设置等待时间。如果设置为10,就像下面的代码一样,如果10秒内没有新消息出现,它将退出。默认值为None,这意味着即使没有新消息传入,使用者也将在此阻塞。</p>
<pre><code> self.consumer = SimpleConsumer(self.client, "test-group", "test",
iter_timeout=10)
</code></pre>
<p><strong>更新</strong></p>
<p>以上不是一个好方法。当大量消息进入时,很难设置足够小的iter_超时来保证停止。所以,现在,我使用get_message()函数,它尝试使用一条消息并停止。没有新消息时不返回任何消息。</p>