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 其他一些脚本工具使用

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容