Kafka使用指南

2021-10-05 11:37:38 字數 1649 閱讀 5843

啟動

bin/zookeeper-server-start.sh config/zookeeper.properties

bin/kafka-server-start.sh config/server.properties停止

bin/kafka-server-stop.sh config/server.properties

bin/zookeeper-server-stop.sh config/zookeeper.properties檢查守護程式jps

基本操作

建立topicbin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic-name

刪除topicbin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic topic_name

修改topicbin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic-name --partitions 2

獲取topic列表bin/kafka-topics.sh --list --zookeeper localhost:2181

檢查哪個**正在監聽當前建立的topicbin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topic-name

單結點-單**

啟動消費者bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic-name --from-beginning

ps: 出現 error while fetching metadata with correlation id : 時,修改 config/server.properties 新增 listeners=plaintext://localhost:9092

啟動生產者bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic-name

單結點-多**

首先將 config/server.properties 複製多份,如 server-one.properties 和 server-two.properties

修改 server-one.properties 和 server-two.properties 中的 broker.id 和 listeners監聽埠 和 log.dirs 為不同值即可

建立主題bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 -partitions 1 --topic topic-name

之後啟動消費者生產者與單**設定相同

Ubuntu apt 使用指南

起初gnu linux系統中只有.tar.gz。使用者必須自己編譯他們想使用的每乙個程式。在debian出現之後,人們認為有必要在系統中新增 一種機制用來管理安裝在計算機上的軟體包。人們將這套系統稱為dpkg。至此著名的 package 首次在gnu linux上出現。不久之後紅帽子也 開始著手建立...

CImageList使用指南

1.綜述 在mfc 中cimagelist 類封裝了 影象列表控制項的功能,影象列表是乙個具有相同大小的 影象 可以是不同 型別 的集合,其主要用於 應用程式中大規模 圖示的儲存。該控制項是不可 見的,通常與其它如 clistbox ccombobox ccomboboxex ctabctrl 以及...

CImageList使用指南

cimagelist使用指南 1.綜述 在 mfc中cimagelist類封裝了影象列表控制項的功能,影象列表是乙個具有相同大小的影象 可以是不同型別 的集合,其主要用於應用程式中大 規模圖示的儲存,該控制項是不可見的。通常與其它如clistbox,ccombobox,ccomboboxex以及ct...