tomcat关闭kafka消费者

关闭Tomcat不会自动关闭Kafka消费者，需要在Tomcat关闭之前手动关闭Kafka消费者。可以在Tomcat的`ServletContextListener`中实现`contextDestroyed`方法，在该方法中关闭Kafka消费者。具体实现可以参考以下代码：

public class KafkaConsumerListener implements ServletContextListener {

    private KafkaConsumer<String, String> consumer;

    @Override
    public void contextInitialized(ServletContextEvent servletContextEvent) {
        // 初始化Kafka消费者
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("group.id", "test-group");
        props.put("enable.auto.commit", "true");
        props.put("auto.commit.interval.ms", "1000");
        props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

        consumer = new KafkaConsumer<>(props);
        consumer.subscribe(Arrays.asList("test-topic"));
    }

    @Override
    public void contextDestroyed(ServletContextEvent servletContextEvent) {
        // 关闭Kafka消费者
        if (consumer != null) {
            consumer.close();
        }
    }
}

然后在`web.xml`中注册该`ServletContextListener`：

<listener>
    <listener-class>com.example.KafkaConsumerListener</listener-class>
</listener>

这样当Tomcat关闭时，`contextDestroyed`方法会被调用，从而关闭Kafka消费者。