Windows下kafka的使用

windows 環境

1.zookeeper 啟動命令 （注意：因我的config在bin同級目錄，故…/…/）

bin/windows/zookeeper-server-start.bat ../../config/zookeeper.properties &

2.kafka 啟動命令 （注意：因我的config在bin同級目錄，故…/…/）

bin/windows/kafka-server-start.bat ../../config/server.properties &

3.建立 topic：

bin/windows/kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

.4.檢視建立的topic

bin/windows/kafka-topics.bat --list --bootstrap-server localhost:9092

啟動生產者producer

bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic test

6.啟動消費者 customer

bin/windows/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

7、生產者**： producer.php

<?php

/** * created by phpstorm.
* user: shiyibo
* date: 2019/2/24
* time: 12:57 pm
*//**
* 訊息生產者
* ** 
*/$objrdkafka
=new
rdkafka\producer()
;$objrdkafka
->
setloglevel
(log_debug);
$objrdkafka
->
addbrokers
("localhost:9092");
$oobjtopic
=$objrdkafka
->
newtopic
("test");
// 從終端接收輸入
$oinputhandler
=fopen
('php://stdin'
,'r');
while
(true
)// 傳送訊息
$oobjtopic
->
produce
(rd_kafka_partition_ua,0
,$smsg);
}echo
"done\n"
;

8、消費者**：consumer.php

<?php

/** * 消費者消費訊息
* ** 
*/$objrdkafka
=new
rdkafka\consumer()
;$objrdkafka
->
setloglevel
(log_debug);
$objrdkafka
->
addbrokers
("localhost:9092");
$oobjtopic
=$objrdkafka
->
newtopic
("test");
/** * consumestart
* 第乙個引數標識分割槽，生產者是往分割槽0傳送的訊息，這裡也從分割槽0拉取訊息
* 第二個引數標識從什麼位置開始拉取訊息，可選值為
* rd_kafka_offset_beginning : 從開始拉取訊息
* rd_kafka_offset_end : 從當前位置開始拉取訊息
* rd_kafka_offset_stored : 猜測跟rd_kafka_offset_end一樣
*/$oobjtopic
->
consumestart(0
,rd_kafka_offset_end);
while
(true)if
($omsg
->
err)
else
}

windows 下 kafka安裝與使用

將 zoo sample.cfg 重新命名為 zoo.cfg datadir tmp zookeeper to d bigdata zookeeper 3.4.10 data或 d bigdata zookeeper 3.4.10 data 路徑僅為示例，具體可根據需要配置 這裡注意，路徑要麼是 分...

Windows下安裝OpenSSL及其使用

1.perl 安裝後重啟系統。2latest openssl 並解壓到 c openssl 0.9.8k。參考openssl 目錄下的 install.win32 說明進行安裝 1 進入解壓目錄。cd c openssl 0.9.8k 2 執行configure。perl configure vc ...

Windows下安裝OpenSSL及其使用

方法一 windows binaries can be found here you can do this conversion with the openssl library 方法二 手動編譯 source 參考openssl目錄下的install.win32說明進行安裝 1 進入解壓目錄。c...