1.安裝git
yum install -y git
2.切換到/usr/local/src目錄,然后將kafka的c客戶端源碼clone到本地
cd /usr/local/src
git clone https://github.com/edenhill/librdkafka
(如果這一步?jīng)]有成功可以使用git --version命令查看當(dāng)前git版本,版本如果為1.7請(qǐng)升級(jí))
3.進(jìn)入到librdkafka,然后進(jìn)行編譯
cd librdkafka
yum install -y gcc
yum install -y?gcc-c++
yum install ?pcre-devel
yum install ??zlib-devel
./configure
make && make install
4.安裝nginx整合kafka的插件,進(jìn)入到/usr/local/src,clone nginx整合kafka的源碼
cd /usr/local/src
git clone https://github.com/brg-liuwei/ngx_kafka_module
(如果報(bào)錯(cuò)可以將https改為git)
5.進(jìn)入到nginx的源碼包目錄下 (編譯nginx,然后將將插件同時(shí)編譯)
cd /usr/local/src/nginx-1.12.2
./configure --add-module=/usr/local/src/ngx_kafka_module/
make
make install
6.修改nginx的配置文件(/usr/local/nginx)

7.啟動(dòng)zk和kafka集群(創(chuàng)建topic)
/bigdata/zookeeper-3.4.9/bin/zkServer.sh start
/bigdata/kafka_2.11-0.10.2.1/bin/kafka-server-start.sh -daemon /bigdata/kafka_2.11-0.10.2.1/config/server.properties
8.啟動(dòng)nginx(/usr/local/nginx),報(bào)錯(cuò),找不到kafka.so.1的文件
error while loading shared libraries: librdkafka.so.1: cannot open shared object file: No such file or directory
9.加載so庫
echo "/usr/local/lib" >> /etc/ld.so.conf
ldconfig
10.測試,向nginx中寫入數(shù)據(jù),然后觀察kafka的消費(fèi)者能不能消費(fèi)到數(shù)據(jù)
curl localhost/kafka/track -d "message send to kafka topic"
curl localhost/kafka/track -d "老趙666"