1.快速開始

本教程假設(shè)你從零開始，沒有已存在的Kafka或zk數(shù)據(jù)

1.1 下載代碼

下載 0.10.0.0 release版本，并解壓

> tar -xzf kafka_2.11-0.10.0.0.tgz > cd kafka_2.11-0.10.0.0

1.2啟動服務(wù)端

Kafka需要zookeeper，如果沒有，需要先啟動zk。你可以使用kafka中打包的腳本啟動一個簡易的單節(jié)點的zk節(jié)點。

> bin/zookeeper-server-start.sh config/zookeeper.properties [2013-04-22 15:01:37,495] INFO Reading configuration from: config/zookeeper.properties (org.apache.zookeeper.server.quorum.QuorumPeerConfig)

然后再啟動kafka服務(wù)器

> bin/kafka-server-start.sh config/server.properties [2013-04-22 15:01:47,028] INFO Verifying properties (kafka.utils.VerifiableProperties) [2013-04-22 15:01:47,051] INFO Property socket.send.buffer.bytes is overridden to 1048576 (kafka.utils.VerifiableProperties)

1.3創(chuàng)建一個主題

創(chuàng)建一個名為"test"的單分片且只有一個副本的主題

> bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

現(xiàn)在，你可以用以下命令查詢主題列表

> bin/kafka-topics.sh --list --zookeeper localhost:2181 test

或者，除了手動創(chuàng)建主題外，也可以配置當(dāng)發(fā)布到一個不存在的主題時自動創(chuàng)建該主題

1.4生產(chǎn)消息

kafka自帶命令行客戶端，可以從文件或標(biāo)準(zhǔn)輸入中獲取數(shù)據(jù)并作為消息輸出到kafka集群。默認每一行作為一條單獨消息。運行producer，在控制臺鍵入一些消息并發(fā)送到服務(wù)端。

> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test This is a message This is another message

1.5消費消息

kafka也有命令行版本的消費者可以將消息下載到標(biāo)準(zhǔn)輸出。

> bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning This is a message This is another message

如果你在不同終端支行以上命令行，你將可以看到生產(chǎn)者終端鍵入消息，消費者終端展示消息。
以上所有的命令行工具都有附加選項，不帶參數(shù)運行以上命令將展示詳細幫助信息。

1.6: 建立多節(jié)點集群

到目前為止，我們已經(jīng)在單節(jié)點運行，但這比較無趣。對kafka來說，單節(jié)點代理是僅有一個節(jié)點的集群。因此啟動多個代理節(jié)點也沒有太多需要變化的。但為了感受一下，我們展示集群到三個節(jié)點（所有的都在本地機器）
首先，為每一個代理節(jié)點建立一個配置文件:

> cp config/server.properties config/server-1.properties > cp config/server.properties config/server-2.properties

然后編輯文件設(shè)置以下屬性：

config/server-1.properties:broker.id=1listeners=PLAINTEXT://:9093log.dir=/tmp/kafka-logs-1config/server-2.properties:broker.id=2listeners=PLAINTEXT://:9094log.dir=/tmp/kafka-logs-2

屬性broker.id是每個節(jié)點在集群中唯一并永久的名稱。由于我們在同一機器上運行，因此需要重寫端口和日志目錄，以保證各節(jié)點使用不同的端口且不發(fā)現(xiàn)數(shù)據(jù)覆蓋。
我們已經(jīng)啟動了zk和單節(jié)點kafka，因此我們僅需要啟動二個新的節(jié)點：

> bin/kafka-server-start.sh config/server-1.properties & > bin/kafka-server-start.sh config/server-2.properties &

轉(zhuǎn)載于:https://www.cnblogs.com/vipmint/p/5974091.html

總結(jié)

以上是生活随笔為你收集整理的Kafka 0.10.0文档翻译二的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。