1. 程式人生 > >Kafka命令列常用命令說明

Kafka命令列常用命令說明

bin/kafka-create-topic.sh   --replica 1 --partition 1 --topic test2 --zookeeper 192.168.197.170:2181,192.168.197.171:2181 結果 topic: test2 partition: 0 leader: 170 replicas: 170 isr: 170

##重新分配分割槽kafka-reassign-partitions.sh

這個命令可以分割槽指定到想要的--broker-list上 bin/kafka-reassign-partitions.sh --topics-to-move-json-file topics-to-move.json --broker-list "171" --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --execute  cat topic-to-move.json {"topics":      [{"topic": "test2"}],      "version":1 }

##為Topic增加 partition數
kafka-add-partitions.sh

bin/kafka-add-partitions.sh --topic test --partition 2  --zookeeper  192.168.197.170:2181,192.168.197.171:2181 (為topic test增加2個分割槽)

##控制檯接收訊息

bin/kafka-console-consumer.sh --zookeeper  192.168.197.170:2181,192.168.197.171:2181  --from-beginning --topic test

##控制檯傳送訊息

bin/kafka-console-producer.sh --broker-list  192.168.197.170:9092,192.168.197.171: 9092    

--topic test 

##手動均衡topic, kafka-preferred-replica-election.sh

bin/kafka-preferred-replica-election.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --path-to-json-file preferred-click.json

cat preferred-click.json
{
 "partitions":
  [
    {"topic": "click", "partition": 0},
    {"topic": "click", "partition": 1},
    {"topic": "click", "partition": 2},
    {"topic": "click", "partition": 3},
    {"topic": "click", "partition": 4},
    {"topic": "click", "partition": 5},
    {"topic": "click", "partition": 6},
    {"topic": "click", "partition": 7},

    {"topic": "play", "partition": 0},
    {"topic": "play", "partition": 1},
    {"topic": "play", "partition": 2},
    {"topic": "play", "partition": 3},
    {"topic": "play", "partition": 4},
    {"topic": "play", "partition": 5},
    {"topic": "play", "partition": 6},
    {"topic": "play", "partition": 7}


  ]
}

相關推薦

Kafka命令常用命令說明

bin/kafka-create-topic.sh   --replica 1 --partition 1 --topic test2 --zookeeper 192.168.197.170:2181,192.168.197.171:2181 結果 topic: test2 partition: 0 le

PostgreSQL命令常用命令

登入資料庫:psql -h localhost -U username -d dbname \c dbname 切換資料庫,相當於mysql的use dbname \l 列舉資料庫,相當於mysql的show databases \dt 列舉表,相當於show tables \d tb

kafka安裝及常用命令

一 kafka安裝啟動 1.下載最新版kafka Apache官網: http://kafka.apache.org/downloads.html 2.解壓kafka tar -zxvf kafka_2.12-1.0.0.tgz 3.重新命名解壓目錄名 mv kaf

git命令常用方法

檢視分支:git branch 建立分支:git branch <name>分支名稱 切換分支:git checkout <name>分支名稱 將原生代碼提交到指定git分支:git push origin  <name>分支名稱 建

Hive命令常用操作(資料庫操作,表操作)

資料庫操作 檢視所有的資料庫 hive> show databases ; 使用資料庫default hive> use default; 檢視資料庫資訊 hive > describe data

kafka安裝及常用命令總結

(五)某個broker掛掉,本機器可重啟 【結論】如果一個broker掛掉,且可以重啟則處理步驟如下: (1)重啟kafka程序 (2)執行rebalance(由於已經設定配置項自動執行balance,因此此步驟一般可忽略) 詳細分析見下面操作過程。 1、topic的情況

HDFS命令客戶端使用,命令客戶端支援的命令引數,常用命令引數介紹

[[email protected] learn]$ hadoop fs help Usage: hadoop fs [generic options]        [-appendToFile <localsrc> ... <dst>]        [-c

【ffmpeg】FFMPEG 命令常用方法示例(包括yuv處理相關命令

Date: 2018.9.20 1、引言 FFMPEG以其強大的功能而在音視訊領域著稱,更重要的是它還是開源的!音視訊格式轉換、裁剪、拼接、提取字幕或某音軌等等,它都能勝任,可謂一把瑞士軍刀,小巧但功能強大,是音視訊研究的必備利器之一。 2、常用命令示例 1、

命令執行常用命令

命令執行常用命令在滲透測試過程中,會遇見一些關於命令執行的漏洞,下面是收集的一些常用命令: ; < > <> | || & && `` () ‘ ‘ 假設一種場景,從前端接收ip比如:127.0.0.1,後端對該ip進行ping測

Laravel 命令常用命令

tar class nan nbsp lis 更新 ocs 令行 target 一、簡介 1、Artisan 是 Laravel 自帶的命令行接口名稱,它為我們在開發過程中提供了很多有用的命令。想要查看所有可用的Artisan命令,可使用list命令: php ar

mongodb linux 命令部分命令

shell相關命令 輸入help可以看到基本操作命令: 連線 ./mongo --port 8000 --host 10.130.161.16   第二種連線方式 mongo IP:埠/資料庫名 -u 使用者名稱 -p 密碼   退出 exit

BAT簡單入門-命令視窗常用命令

命令視窗常用命令 1、cd 命令 cd       //顯示當前目錄 cd ..       //退出到上一個目錄 cd /d D:      //進入上次D盤所在目錄 cd /d d:\&nbs

DOS 命令基本命令及實踐

1. DOS命令簡介 DOS命令,計算機術語,是指DOS作業系統的命令,是一種面向磁碟的操作命令,主要包括目錄操作類命令、磁碟操作類命令、檔案操作類命令和其它命令。 2. DOS命令開啟 若使用window ,可用windows + s 或者 windows +

mongodb的命令操作命令詳解(增刪改查、高階查詢)

本文為上文的續篇,主要講解mongodb在cmd的直接操作命令,我的mongodb是安裝在d:\mongodb下 1,mongodb啟動服務 : 命令列方式啟動: . 直接cmd下進入mongodb的bin目錄,輸入mongod.exe –dbpath

mongodb 命令基本命令使用大全

(先宣告下,下面的命令,我沒有都測試過,這是我轉載的,以備後用,所以噴子且留情,不然小心我三十米的大刀!!!想想我都怕!!!) 成功啟動MongoDB後,再開啟一個命令列視窗輸入mongo,就可以進行資料庫的一些操作。 輸入help可以看到基本操作命令: show dbs:

Python Flask,flask_script,擴充套件指令碼,擴充套件命令命令中啟動Flask

  安裝flask_script包: pip install Flask-Script   demo.py(flask_script): # coding:utf-8 from flask import Flask from flask_script impor

Linux命令——touch命令詳解

1.命令功能   touch命令用於建立檔案或修改檔案/目錄的時間戳(瞭解時間戳,可以檢視Linux命令列——stat命令詳解)。 2.語法格式   touch [option] file

Windows命令route命令使用圖解

一 操作例項 檢視當前本機的路由表; 有三部分,介面列表,IPv4路由表,IPv6路由表; 檢視0.打頭的路由表資訊; 新增一條 新增預設閘道器地址為192.168.12.1的預設路由 ; 刪除前面新增的路由; 新增躍點數為7的路由; 刪除之; 新增

把git倉庫從碼雲遷到github,及git常用命令 git常用命令--持續更新

  前言 剛開始建倉庫的時候,因為網路的原因選擇了國內的碼雲。後來又想換成github,畢竟平時github使用率比較高。   替換遠端倉庫地址方式如下: git remote set-url origin 你新的遠端倉庫地址   另附上git常用命令

java專案打成可在命令命令執行的jar包

一、java專案沒有匯入第三方jar包這時候打包就比較簡單:1. 首先在MyEclipse(或者Eclipse)中開啟專案, 右鍵點選專案,選擇“Export”;2. 選擇Java/JAR file,Next;3. Select the resources to expor