首先，我在这方面是新的，所以可能是对问题的解释不准确。
我有一个关于Kafka的主题和一些数据。对于使用者（用scala编写），我想连接到服务器并使用该信息。问题是，我认为在某些执行中，消费者没有正确关闭，现在它阻塞了读数。
我遵循了这个准则。
如何创建非阻塞连接来读取主题？
如果你需要更多的细节，请告诉我。