版权声明:欢迎转载,转载请说明出处https://csdn.yanxml.com。大数据Github项目地址https://github.com/SeanYanxml/bigdata。 https://blog.csdn.net/u010416101/article/details/81165578
前言
一般需要使用的Kafka原生命令多位于bin
目录,其下使用较多的脚本如下
- kafka-topics.sh
- kafka-console-producer.sh
- kafka-console-consumer.sh
- kafka-acls.sh
- kafka-consumer-groups.sh
- kafka-server-start.sh
- kafka-server-stop.sh
Kafka Orders
- Topic相关(创建/查询/删除/修改分片/平衡leader)
.-. -- -- ...,...
.-. -- ...,... -- -- -
-
.-. -- -- ... --- -- -- -
.-. -- ... -- -- - --
...
.-. -- ... -- -- -
.---. --
.--. --- ... -- -
.--. -- ... -- - ---
.+
.--. --- -- - --. .
.+
.--. --- -- - --- --- --. .
.---. -- -- - -- -- ---
# sasl consumer
./kafka-console-consumer.sh --bootstrap-server 192.168.100.87:9093,192.168.100.88:9093,192.168.100.89:9093 --topic bmc-events-topic-dev --consumer.config ../config/consumer.properties --new-consumer
# sasl producer
./kafka-console-producer.sh --broker-list 192.168.100.87:9093 --topic bmc-events-topic-dev --producer.config ../config/consumer.properties
.-. --- .... -- --- -- -- -- ---
.-. --- .... -- -- -
.-. --- .... -- --- --- -- -- -- ---
.--. .. -- ... -- -- -
.--. .. --- ... -- - -- -
.--. --- ...,...,... --- ... --
.--. --- ... --- ... -- -- --
.--. --- ... --- ... -- -- -- +
.--. --- ...,...,... -- - --. ... ---
.--. --- ... --- ... -- --
.-. -- -- ...
.--. --- ...,...,... --- ... -- -- -- +
.--. --- ...,...,... --- ... -- -- -- +
Reference
[1]. JIRA-KAFKA-3151(SASL)
[2]. kafka命令大全(orchome.com)
[3]. Kafka命令行常用命令说明
[4]. Kafka常用命令(csdn.yanxml)
[5]. Kafka常用命令行总结
Others
bin
目录下的所有脚本,分析作用如下:
# version kafka-1.0.0
# kakfa 相关
connect-standalone.sh
connect-distributed.sh
# consumer
kafka-consumer-groups.sh
kafka-consumer-perf-test.sh
kafka-console-consumer.sh
kafka-simple-consumer-shell.sh
# producer
kafka-console-producer.sh
kafka-producer-perf-test.sh
# broker 启/停
kafka-server-stop.sh
kafka-server-start.sh
kafka-broker-api-versions.sh
# topic
kafka-topics.sh
# acls 权限
kafka-acls.sh
# others
# kafka config 配置
kafka-configs.sh
# 重新分片 partition
kafka-reassign-partitions.sh
# reset kafka streaming
kafka-streams-application-reset.sh
kafka-replay-log-producer.sh
kafka-delete-records.sh
kafka-replica-verification.sh
kafka-verifiable-consumer.sh
kafka-log-dirs.sh
kafka-verifiable-producer.sh
kafka-mirror-maker.sh
trogdor.sh
kafka-preferred-replica-election.sh
# run-class
kafka-run-class.sh
# 内置ZooKeeper相关
zookeeper-shell.sh
zookeeper-server-start.sh
zookeeper-server-stop.sh
zookeeper-security-migration.sh
# windows脚本 文件夹
windows/