擅长:python、mysql、java
<p>我终于成功了。最初我运行了<a href="https://github.com/confluentinc/confluent-kafka-python" rel="nofollow noreferrer">confluent-kafka tutorial</a>,它:</p>
<ul>
<li>不捕获<code>ctrl+c</code>SIGINT信号</li>
<li>在<code>poll()</code>时不超时</li>
</ul>
<p>在消费者守则中。因此,我不得不在我的linux机器上<code>ctrl+z</code>然后<code>kill %1</code>。我相信这个终端并没有关闭一段时间保持打开状态的套接字(<code>TIME_WAIT</code>)。当我重新启动消费者时,它从旧插座中取出垃圾,卡住了。在</p>
<p>我添加了<code>try: [...] except KeyboardInterrupt: consumer.close()</code>来捕获{<cd1>}并干净地关闭套接字。不再面对这个问题。在</p>
<p>我希望这对将来的人有帮助。在</p>