kafka伪集群搭建

下载地址：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

创建查看删除操作 topic的分区副本详细信息

kafka-configs.sh 对topic broker client配置修改的工具

todo 其他一些脚本工具使用