下载地址:http://kafka.apache.org/downloads 我装的是0.10.2.1,tar zxvf解压指令
1、先启动zookeeper,可选择kafka自带的,也可用独立的zookeeper
nohup bash zookeeper-server-start.sh ../config/zookeeper.properties &
2、准备kafka服务端配置文件
在conf下copy出三份配置文件server.properties,修改其中的broker.id(机器号)、listeners(监听的ip和端口)、log.dir(消息日志目录)信息区分出来“三台”服务器。多加了default.replication.factor = 3,表示建立的partition默认有三个replica(副本);delete.topic.enable=true,支持topic删除功能,默认配置是false。其余使用提供的默认的配置。分别启动
服务端参数含义可参考http://orchome.com/12,另外服务端提供的消费者和生产者配置。可选择不配置,在客户端代码里配置。
默认内存是1G,kafka-server-start.sh可修改
kafka提供了很方便的命令行工具
kafka-topics.sh topic的增加删除查的操作
./kafka-topics.sh --zookeeper 127.0.0.1:2181 --create --topic "kafka10-topic-20170922" --partitions 3 --replication-factor 3
创建一个topic,3个分区,3个副本,名字kafka10-topic-20170922
kafka-configs.sh 对topic broker client配置修改的工具
todo 其他一些脚本工具使用