溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

kafka0.10.0單機(jī)測(cè)試

發(fā)布時(shí)間：2020-06-24 06:37:10 來(lái)源：網(wǎng)絡(luò) 閱讀：1029 作者：guhongzi 欄目：開(kāi)發(fā)技術(shù)

剛開(kāi)始折騰kafka，單機(jī)版測(cè)試成功 單機(jī)版很簡(jiǎn)單，按照文檔下載執(zhí)行即可

前提是安裝好java 配置好環(huán)境變量

  1. 從kafka站點(diǎn)下載最新的kafka

  2. 解壓到執(zhí)行目錄

  3. 啟動(dòng)zookeeper 服務(wù) bin/zookeeper-server-start.sh config/zookeeper.properties

  4. 啟動(dòng)kafka服務(wù) bin/kafka-server-start.sh config/server.properties

  5. 創(chuàng)建topic bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

  6. 查看創(chuàng)建的topic  bin/kafka-topics.sh --list --zookeeper localhost:2181

  7. 生產(chǎn)消息并發(fā)送到服務(wù)端 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

  8. 在消費(fèi)端查看消息 bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

kafka0.10.0單機(jī)測(cè)試

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手