KafkaConsumer.close() 为什么？

Question

我在这里询问关闭 kafka 消费者。即使使用线程退出，我是否需要关闭 kafka 使用者？关闭它会不会因为任何变化而泄漏资源？

这是一个代码示例：

public class MyThread extends Thread{

    private KafkaConsumer<String, Message> kafkaConsumer;


    @Override
    public void run() {
        kafkaConsumer = initConsumer();
        while(true){
            kafkaconsumer.poll(1000000)
            //Code goes here.
        }
    }
}

是否kafkaConsumer在关闭MyThread退出使用System.exit？

Answer 1

引自 Gwen Shapira、Neha Narkhede、Todd Palino（O'Reilly Media）的“卡夫卡——权威指南”：

在退出之前始终关闭（）消费者。这将关闭网络连接和套接字。它还会立即触发重新平衡，而不是等待组协调器发现消费者停止发送心跳并且可能已经死亡，这将花费更长的时间，因此导致消费者无法在更长的时间内消费来自分区的子集。

Kafka - 权威指南