搭建kafka環境

2021-07-11 14:58:36 字數 1043 閱讀 1088

步驟2：啟動zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties
步驟3：修改配置檔案config/server.properties，新增如下內容

host.name=localhost


advertised.host.name=localhost
步驟4：啟動kafka server

bin/kafka-server-start.sh config/server.properties
步驟5：建立topic

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1  --topic test
檢驗topic建立是否成功

bin/kafka-topics.sh --list --zookeeper localhost:2181
如果正常返回test

步驟6：開啟producer，傳送訊息

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


##啟動成功後，輸入以下內容測試


this is a message


this is another message
步驟7：開啟consumer，接收訊息

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning


###啟動成功後，如果一切正常將會顯示producer端輸入的內容


this is a message


this is another message

kafka環境搭建

1.拉取映象 docker pull kafkamanager kafka manager2.啟動映象 ezk hosts 1.2.3.4 宿主機ip 9000 預設埠 4.解決yikes ask timed out on actorselection anchor akka kafka manag...

kafka 單機環境kafka搭建

目錄 一 kafka搭建方法 二 kafka常用命令行 1.topic建立 2.命令列生產者 3.命令列消費者 step1 解壓kafka tar zxvf kafka 2.13 2.4.0.tgzstep2 啟動zookeeper bin zookeeper server start.sh con...

Kafka學習筆記 Kafka環境搭建

1.將kafka的tar包上傳到測試環境，解壓到 opt software，配置環境變數 kafka home opt software kafka 2.11 1.1.0 path kafka home bin scala home bin path export kafka home export...