官方的网站:http://kafka.apache.org
官方的下载:http://kafka.apache.org/downloads
选择使用scala2.11编译kafka最新稳定版本: kafka_2.11-0.10.1.1.tgz
也可以从本人的百度网盘中下载:https://pan.baidu.com/s/1qY533tE
安装
下载的是已经使用scala编译过的,可以直接使用。但在使用前需要安装zookeeper,安装zookeeper
参考:Zookeeper的安装、Zookeeper配置
配置zookeeper后,采用如下的代码启动:
./kafka-server-start.sh ../config/server.properties &
kafka的详细配置参考:kafka的配置
命令
在bin的目录下(除windows外)有众多的shell脚本,这些都是kafka的管理命令,是不是觉得有点多,下面
来逐个介绍下:
connect-distributed.sh
distributed的中文释义分布式,
connect-standalone.sh
kafka-acls.sh
kafka-configs.sh
kafka-console-consumer.sh
kafka-console-producer.sh
kafka-consumer-groups.sh
kafka-consumer-offset-checker.sh
kafka-consumer-perf-test.sh
kafka-mirror-maker.sh
kafka-preferred-replica-election.sh
kafka-producer-perf-test.sh
kafka-reassign-partitions.sh
kafka-replay-log-producer.sh
kafka-replica-verification.sh
kafka-run-class.sh
kafka-server-start.sh
# daemon的形式启动 ./kafka-server-start.sh -daemon ../config/server.properties # 对应的config配置参考:kafka的配置
kafka-server-stop.sh
# ./kafka-server-stop.sh
kafka-simple-consumer-shell.sh
kafka-streams-application-reset.sh
kafka-topics.sh
kafka-verifiable-consumer.sh
kafka-verifiable-producer.sh
zookeeper的四个脚本,在这里不介绍,可参考:Zookeeper中的命
啊
啊