'KafkaConsumer<String, String>' used without 'try'-with-resources statement

这个警告是因为 `KafkaConsumer` 实现了 `java.lang.AutoCloseable` 接口，需要使用 try-with-resources 语句来自动关闭 `KafkaConsumer` 实例。

使用 try-with-resources 语句可以自动关闭 `KafkaConsumer` 实例，避免资源泄露。例如：

try (KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props)) {
    consumer.subscribe(Arrays.asList("topic1", "topic2"));
    while (true) {
        ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
        for (ConsumerRecord<String, String> record : records) {
            System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
        }
    }
} catch (Exception e) {
    e.printStackTrace();
}

在这个例子中，我们使用 try-with-resources 语句来创建 `KafkaConsumer` 实例，并在 try 块结束时自动调用 `close` 方法关闭实例。这样可以避免资源泄露，并且代码更加简洁。如果在 try 块中发生异常，也不需要手动关闭 `KafkaConsumer` 实例，它会自动被关闭。

需要注意的是，在使用 try-with-resources 语句时，需要将 `KafkaConsumer` 实例的声明放在 try-with-resources 语句的括号中，确保在 try 块结束时自动关闭实例。同时，需要捕获异常，避免异常导致程序崩溃。