KafkaConsumer 非阻塞

KafkaConsumer 在默认情况下是阻塞的，意思是当没有可用的消息时，它会等待新的消息到达。然而，如果你想让 KafkaConsumer 变成非阻塞的，有一些方法可以实现。

一种方法是使用 `poll()` 方法来控制消费者的阻塞行为。`poll()` 方法可以设置一个超时时间参数，如果在指定的时间内没有可用消息，它将立即返回。这样你可以在调用 `poll()` 之后执行其他操作，而不会被阻塞住。你可以根据自己的需求设定合适的超时时间。

另一种方法是使用多线程来消费消息。你可以创建多个消费者线程，并行地从 Kafka 中获取消息。这样即使一个线程被阻塞了，其他线程仍然可以继续处理消息。这种方式需要额外的线程管理和同步操作，但可以提高消费的并发性和响应性。

需要注意的是，在实现非阻塞消费时，你可能会面临一些挑战，比如处理消息顺序、处理重复消息等问题。你需要根据你的应用需求和场景来选择合适的非阻塞消费方式，并做好相应的处理和容错机制。