KafkaConsumer close() 抛出 ConcurrentModificationException [关闭]

Question

private final CopyOnWriteArrayList<Closeable> openedResources = new CopyOnWriteArrayList<>();
final KafkaConsumer<String, byte[]> consumer = new KafkaConsumer<>(clientConfig);

public synchronized void close() {
    try {
        consumer.close();
        openedResources.remove(consumer);
    } catch (Exception exception) {
        LOGGER.warn("Problem while closing", exception);
    }
}

每当我从我自己的方法实现中显式调用 KafkaConsumer close() 时，就会抛出并发修改异常。

我试图关闭连接，但由于异常我无法这样做。