1.jdk 1.8
2.zookeeper 3.4.8 解壓
3.kafka 配置
在kafka解壓目錄下下有乙個config的資料夾，裡面放置的是我們的配置檔案
consumer.properites 消費者配置，這個配置檔案用於配置於2.5節中開啟的消費者，此處我們使用預設的即可
producer.properties 生產者配置，這個配置檔案用於配置於2.5節中開啟的生產者，此處我們使用預設的即可
server.properties kafka伺服器的配置，此配置檔案用來配置kafka伺服器，目前僅介紹幾個最基礎的配置
broker.id 申明當前kafka伺服器在集群中的唯一id，需配置為integer,並且集群中的每乙個kafka伺服器的id都應是唯一的，我們這裡採用預設配置即可
listeners=plaintext:// 192.168.180.128:9092。並確保伺服器的9092埠能夠訪問
3.zookeeper.connect 申明kafka所連線的zookeeper的位址 ，需配置為zookeeper的位址，由於本次使用的是kafka高版本中自帶zookeeper，使用預設配置即可
zookeeper.connect=localhost:2181
4.執行 zookeeper 我是到zookeeper bin 目錄下啟動 命令：sh zkservwer.sh start
5.啟動 kafka
因為搭建的不是集群 所以都是採用預設配置 kafka 啟動命令：到kafka bin 下 ./bin/kafka-server-start.sh config/server.properties 成功如下：
6.topic測試
1）在kafka解壓目錄開啟終端，輸入
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topictest
建立乙個名為test的topic
2）檢視是否建立成功
./kafka-topics.sh --list --zookeeper localhost:2181會出現 test
3）建立乙個訊息消費者
在kafka解壓目錄開啟終端，輸入
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topictest--from-beginning
可以建立乙個用於消費topic為test的消費者 此時相當於乙個控制台 不會有任何輸出
4）建立乙個訊息生產者
在kafka解壓目錄開啟乙個新的終端，輸入
5）消費輸出：
LAMP環境搭建 php環境搭建
yum groupinstall development tools y yum groupinstall desktop platform development y yum install cmake pcre devel ncurses devel openssl devel libcurl ...
環境搭建 二 Python環境搭建
工欲善其事，必先利其器 要想玩轉python，我們首先需要搭建一套可使用且方便的環境。對於初學者，笨飯糰建議使用 anaconda anaconda 簡介anaconda是python的乙個科學計算發行版，內建了數百個python經常會使用的庫，包括做機器學習或資料探勘的庫。anaconda提供了乙...
kafka linux 客戶端操作命令
生產命令 消費命令 topic刪除命令 topic描述命令 在linux執行kafka bin kafka server start config server.properties 1.建立乙個topic kafka home bin kafka topics.sh create zookeepe...