一、版本说明
- jdk : 1.7
- zk : zookeeper-3.4.6.tar.gz
- kafka : kafka_2.11-0.8.2.1.tgz
二、zk搭建
2.1 创建安装目录，并将zk的安装文件放到对应目录
2.2 解压文件
2.3 修改配置文件zoo.cfg
2.4 启动zk：bin/zkServer.sh start
2.5 常用命令
- 查看zk状态：bin/zkServer.sh status
- 登录zk服务器：bin/zkCli.sh -server localhost:2181
- zk节点操作
三、kafka搭建
3.1 创建安装目录，并将kafka的安装文件放到对应目录
3.2 解压文件
3.3 修改配置文件，主要参数为：
log.dirs=/data/kafka/kafka-logs
zookeeper.connect=127.0.0.1:2181
3.4 启动kafka
3.5 kafka常用命令
- --list topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
- --create a topic
bin/kafka-topics.sh --create --zookeeper localhost:2181--replication-factor 1 --partitions 1 --topic topic_zl
- --Send some messages
bin/kafka-console-producer.sh --broker-list localhost:9092 --topictopic_zl
- --Start a consumer
bin/kafka-console-consumer.sh--bootstrap-server localhost:9092 --topic topic_zl --from-beginning
- --describe topics
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topictopic_zl
- --__consumer_offsets
bin/kafka-simple-consumer-shell.sh--topic __consumer_offsets --partition 40 --broker-list 127.0.0.1:9092
-- formatter "kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter"