kafka的一些常用命令

2021-08-20 11:13:59 字數 2174 閱讀 9101

啟動zookeeper

如果該命令執行不成功,看是否當前進入kafka目錄。

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

啟動kafka

bin/kafka-server-start.sh config/server.properties &

停止kafka

bin/kafka-server-stop.sh

停止zookeeper

bin/zookeeper-server-stop.sh

建立topic

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

localhost可以換成,想要檢視伺服器的位址。

展示topic

bin/kafka-topics.sh --list --zookeeper localhost:2181

描述topic

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic

加上--describe 可以檢視該topic 下面的分割槽數,和一些描述資訊

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic windows --describe

生產者:

bin/kafka-console-producer.sh --broker-list 130.51.23.95:9092 --topic my-replicated-topic

消費者:

bin/kafka-console-consumer.sh --zookeeper 130.51.23.95:2181 --topic test --from-beginnin

# 建立topic

[kafka@kafka bin]$ ./kafka-topics.sh --zookeeper localhost:2181 --create --topic topic-name --partitions 10 --replication-factor 1

created topic "topic-name".

# 檢視建立的所有的topic

[kafka@kafka bin]$ ./kafka-topics.sh --list --zookeeper localhost:2181

# 檢視某個topic的狀態

[kafka@kafka bin]$ ./kafka-topics.sh --describe --zookeeper localhost:2181 --topic topic-name

# 訊息的訂閱者

[kafka@kafka bin]$ ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic topic-name --from-beginning(在0.10.2.1版本之前使用,在新版本中不建議再使用)

[kafka@kafka bin]$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic-name --from-beginning

# 訊息的發布者

[kafka@kafka bin]$ ./kafka-console-producer.sh --broker-list localhost:9092 --topic topic-name

刪除topic bin/kafka-topics.sh --delete --zookeeper 130.51.23.95:2181 --topic topicname刪除topic中儲存的內容在config/server.properties中找到如下的位置

刪除log.dirs指定的檔案目錄,然後重新啟動就可以了

一些常用命令

7 12 chmod rwx rw rw u 檔案擁有者 g 所屬的使用者組 o 其它使用者 mount mount t 檔案型別 需要掛載的檔案系統 掛載點 umount umount 掛載點 tar c create 建立 x extract v verbose 顯示資訊 z gzip tar....

一些常用命令

df h 顯示分割槽空間 du 顯示目錄或檔案的大小 fdisk 分割槽設定 fdisk l dev hda 顯示硬碟分割槽狀態 mkfs 建立各種檔案系統 mkfs t ext3 dev ram15 fsck 檢查和修復linux檔案 mke2fs 格式化 mkfs t ext3 dd if et...

mysql一些常用命令

mysql一些常用命令 一 連線mysql。格式 mysql h主機位址 u使用者名稱 p使用者密碼 1 連線到本機上的mysql。首先開啟dos視窗,然後進入目錄mysql bin,再鍵入命令mysql u root p,回車後提示你輸密碼.注意使用者名稱前可以有空格也可以沒有空格,但是密碼前必須...