1.快速開始

本教程假設你從零開始，沒有已存在的Kafka或zk數據

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啟動服務端

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

> 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服務器

> 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創建一個主題

創建一個名為"test"的單分片且只有一個副本的主題

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

現在，你可以用以下命令查詢主題列表

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

或者，除了手動創建主題外，也可以配置當發布到一個不存在的主題時自動創建該主題

1.4生產消息

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

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

1.5消費消息

kafka也有命令行版本的消費者可以將消息下載到標準輸出。

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

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

1.6: 建立多節點集群

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

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

然后編輯文件設置以下屬性：

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是每個節點在集群中唯一并永久的名稱。由于我們在同一機器上運行，因此需要重寫端口和日志目錄，以保證各節點使用不同的端口且不發現數據覆蓋。
我們已經啟動了zk和單節點kafka，因此我們僅需要啟動二個新的節點：

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

轉載于:https://www.cnblogs.com/vipmint/p/5974091.html

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。