分布式消息服務(wù)器kafka

創(chuàng)新互聯(lián)堅(jiān)持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：成都網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計(jì)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時(shí)代的剛察網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

##搭建過程：
步驟：
1：下載代碼，解壓
2：?jiǎn)?dòng)zookeeper服務(wù)器：bin/zookeeper-server-start.sh config/zookeeper.properties
3：?jiǎn)?dòng)kafka服務(wù)器：bin/kafka-server-start.sh config/server.properties
4：創(chuàng)建一個(gè)topic：bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytopic
查看是否創(chuàng)建成功：bin/kafka-topics.sh --list --zookeeper localhost:2181
5：發(fā)送消息：bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic
6：?jiǎn)?dòng)一個(gè)消費(fèi)者：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytopic --from-begining