小编Moh*_*med的帖子

我在这里询问关闭 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？