Kafka 0.10.1.0 Cluster搭建

1、Kafka集群搭建:Kafka集群搭建涉及到Zookeeper的安装,Kafka的安装,以及Kafka的配置,具体安装步骤如下:

(1)安装Zookeeper:安装Zookeeper,首先需要下载并解压Zookeeper的安装包,然后在conf文件夹下面修改zoo.cfg文件,添加dataDir和clientPort等配置,最后在bin文件夹下面启动zkServer.sh脚本即可。

(2)安装Kafka:安装Kafka,首先需要下载并解压Kafka的安装包,然后在config文件夹下面修改server.properties文件,添加broker.id、zookeeper.connect等配置,最后在bin文件夹下面启动kafka-server-start.sh脚本即可。

Topic简单操作

2、Topic简单操作:Kafka的Topic简单操作包括创建Topic,查看Topic列表,以及删除Topic等,具体操作步骤如下:

(1)创建Topic:在Kafka的bin文件夹下面执行kafka-topics.sh脚本,并加上创建Topic的参数,如--zookeeper localhost:2181 --create --topic test --partitions 3 --replication-factor 1,即可创建一个名为test的Topic,其分区数为3,副本数为1。

(2)查看Topic列表:在Kafka的bin文件夹下面执行kafka-topics.sh脚本,并加上查看Topic列表的参数,如--zookeeper localhost:2181 --list,即可查看当前Kafka集群中所有的Topic列表。

(3)删除Topic:在Kafka的bin文件夹下面执行kafka-topics.sh脚本,并加上删除Topic的参数,如--zookeeper localhost:2181 --delete --topic test,即可删除名为test的Topic。