Kafka Consumer多線程消費實戰和源碼分析

根據官方文檔我們知道KafkaConsumer是線程不安全的,KafkaProducer是線程安全的。接下來我們就來討論爲什麼KafkaConsumer線程不安全 1、kafka的消費者和分區的關係: topic下的一個分區只能被同一個consumer group下的一個consumer線程來消費,但反之並不成立, 即一個consumer線程可以消費多個分區的數據,比如Kafka提供的Consol
相關文章
相關標籤/搜索