使用兩種多線程模式消費kafka數據

使用兩種多線程模式消費數據 KafkaProducer是線程安全的,然而 KafkaConsumer倒是非線程安全的。 Kafka Consumer中定義了一個 acquire(方法,用來檢測當前是否只有一個線程在操做,如有其餘線程正在操做則會拋出 Concurrentmodifcationexception異常:java java.util.ConcurrentModificationExcep

>>阅读原文<<