?
?
不多說,直接上干貨!
?
一切來源于官網
http://kafka.apache.org/documentation/
?
?
?
?
?
2.2 Consumer API
2.2、消費者API
?
?
隨著0.9.0版本,我們已經增加了一個新的Java消費者替換我們現有的基于zookeeper的高級和低級消費者。
這個客戶端還是測試版的質量。為了確保用戶平滑升級,
我們仍然維護舊的0.8版本的消費者客戶端繼續在0.9集群上工作,
兩個老的0.8 API的消費者( 高級消費者 和 低級消費者)。
?
?
The Consumer API allows applications to read streams of data from topics in the Kafka cluster.
?
Examples showing how to use the consumer are given in the?javadocs.
?
?
To use the consumer, you can use the following maven dependency:
對于使用生產者,你可以使用以下的maven依賴
<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>0.10.2.0</version></dependency>
如何使用新的消費者,請請見如下
kafka消費者客戶端(0.10.0.1API)
http://orchome.com/451
?
kafka消費者客戶端(0.9.0.1API)
http://orchome.com/203
?
kafka消費者低級實例
http://orchome.com/11
?
?
?
kafka舊高級消費者API
http://orchome.com/9
?
?
?
?