使用两种多线程模式消费kafka数据

使用两种多线程模式消费数据 KafkaProducer是线程安全的,然而 KafkaConsumer倒是非线程安全的。 Kafka Consumer中定义了一个 acquire(方法,用来检测当前是否只有一个线程在操做,如有其余线程正在操做则会抛出 Concurrentmodifcationexception异常:java java.util.ConcurrentModificationExcep

>>阅读原文<<