kafka系列教程03 kafka命令大全

## 建立主題（4個分割槽，2個副本）

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

## 查詢集群描述

bin/kafka-topics.sh --describe --zookeeper 
## 消費者列表查詢
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
## 新消費者列表查詢（支援0.9版本+）
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
## 顯示某個消費組的消費詳情（僅支援offset儲存在zookeeper上的）
bin/kafka-run-class.sh kafka.tools.consumeroffsetchecker --zookeeper localhost:2181 --group test
## 顯示某個消費組的消費詳情（支援0.9版本+）
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group

## 生產者

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
## 消費者
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test
## 新生產者（支援0.9版本+）
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test --producer.config config/producer.properties
## 新消費者（支援0.9版本+）
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --new-consumer --from-beginning --consumer.config config/consumer.properties
## 高階點的用法
bin/kafka-******-consumer-shell.sh --brist localhost:9092 --topic test --partition 0 --offset 1234 --max-messages 10

bin/kafka-preferred-replica-election.sh --zookeeper zk_host:port/chroot

bin/kafka-producer-perf-test.sh --topic test --num-records 100 --record-size 1 --throughput 100  --producer-props bootstrap.servers=localhost:9092

cat > increase-replication-factor.json <

執行bin/kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file increase-replication-factor.json --execute

驗證

bin/kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file increase-replication-factor.json --verify

kafka系列教程01 如何學習kafka

資料流，如訊息傳遞系統 高效並實時 資料流安全地在分布式集群中複製儲存 kafka是用於構建實時資料管道和流應用程式。具有橫向擴充套件，容錯，wicked fast 快 等優點，並已在成千上萬家公司執行。apache kafka是訊息中介軟體的一種，我發現很多人不知道訊息中介軟體是什麼，在開始學習之...

Spring系列教程 03Spring容器的建立

new beans.xml 第二種 檔案系統路徑獲得配置檔案 絕對路徑 new d springframework講解 src beans.xml 第三種 使用beanfactory 了解 newxmlbeanfactory new filesystemresource d springframew...

MATLAB教程系列 台大 03 exercise

第三課中的練習，溫度轉換。要求，除非輸入的不是數字，程式停止，否則一直提示輸入溫度。function y ftoc f tips1 temperature in f is f input tips1 while isnumeric f 1 isempty f 0 isempty str2num f ...