java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access

您提到的 `java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access` 异常是由于 KafkaConsumer 不支持多线程访问导致的。afkaConsumer 是线程不安全的，它的设计初衷是每个线程拥有一个独立的 KafkaConsumer 实例。

如果您需要在多个线程中使用 KafkaConsumer，可以考虑以下两种方式：

1. 单线程消费：在单个线程中创建 KafkaConsumer 实例，并在该线程中进行所有的消费操作。这样可以避免多线程访问的问题，并保持消费的顺序性。

2. 线程封闭：如果您确实需要在多个线程中使用 KafkaConsumer，可以采用线程封闭的方式，即为每个线程创建一个独立的 KafkaConsumer 实例，并在每个线程内部进行操作。这样可以避免多线程间的竞争和冲突。

无论选择哪种方式，都需要确保在不同线程间没有共享 KafkaConsumer 实例，以避免并发访问导致的异常。

另外，如果您需要进行多线程消费，还可以考虑使用高级消费者 API（Consumer Group）来实现多个消费者实例并发地消费同一个主题的分区。这种方式下，每个消费者实例都是单线程的，而多个实例可以并行地消费不同分区的消息。这样可以提高消费的吞吐量。