Kafka指令碼命令使用彙總

./kafka-server-start.sh -daemon ../config/server.properties

./kafka-server-stop.sh

ps aux | grep kafka

kill -9 pid

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

或./kafka-topics.sh --list --bootstrap-server hadoop1:9092,hadoop2:9092

./kafka-console-producer.sh --zookeeper localhost:2181 --topic topicname

或./kafka-console-producer.sh --broker-list hadoop1:9092,hadoop2:9092,hadoop3:9092 --topic topicname

./kafka-console-consumer.sh --zookeeper localhost:2181 --topic topicname

或./kafka-console-consumer.sh --bootstrap-server hadoop1:9092,hadoop2:9092 --topic topicname

./kafka-topics.sh --zookeeper localhost:2181 --describe --topic topicname

./kafka-run-class.sh kafka.admin.deletetopiccommand --zookeeper localhost:2181 --topic topicname

./kafka-acls.sh 

--authorizer-properties zookeeper.connect=zookeeper.example.com:2181 
--add --allow-principal user:"kafkaclient"
--producer
--topic "topicname"

./kafka-acls.sh --authorizer-properties zookeeper.connect=ip:port,ip:port,ip:port --list --topic topicname

對於消費者，kafka中有兩個設定的地方：

對於老的消費者，由--zookeeper引數設定；

對於新的消費者，由--bootstrap-server引數設定。

對於console生產者：

--broker-list引數指定了所使用的broker。

kafka基本命令使用

本文主要參考 最近開始接觸kafka，下面介紹介紹一些最基本的kafka 的操作。首先是啟動kafka。kafka依賴zookeeper，所以需要先啟動zookeeper。bin zookeeper server start.sh config zookeeper.properties然後啟動kaf...

指標使用彙總

include int main include include void f int p 3 4 原始型別 void f int p 4 省略第一維長度 void f int p 4 指標 指向乙個陣列，陣列中的每個元素是int型別 void f int p error 不能將第二維退化為指標 v...

Tomcat使用彙總

使用tomcat部署web應用一定要重啟！重啟！重啟。搞了三天的web程式部署，倒在了tomcat上，記錄這幾天使用的心得，防止自己下次再犯。tomcat伺服器檔案的結構 server.xml被稱為tomcat的主配置檔案或者全域性配置檔案，他主要完成 1.提供tomcat元件的初始配置 2.說明t...