kafka集群搭建与使用

1、准备环境

　　1.1安装jdk（省略）

　　2.2安装zookeeper集群（省略）

2、下载安装包并解压

# wget https://archive.apache.org/dist/kafka/1.1.0/kafka_2.11-1.1.0.tgz
# tar -xzf kafka_2.11-1.1.0.tgz
# cd kafka_2.11-1.1.0

 

3、修改配置文件 分别在128，129，130上修改

broker.id=0  每台服务器的broker.id都不能相同

#hostname
host.name=192.168.0.128

#设置zookeeper的连接端口
zookeeper.connect=192.168.0.128:2181,192.168.0.129:2181,192.168.0.130:2181

 

4、启动  三台都要启动

 sh bin/kafka-server-start.sh -daemon config/server.properties

 

5、创建主题

sh bin/kafka-topics.sh --create --zookeeper 192.168.0.128:2181 --replication-factor 2 --partitions 1 --topic houge

##查看主题
sh bin/kafka-topics.sh --list --zookeeper 192.168.0.128:2181
##查看主题详细信息
sh bin/kafka-topic.sh --describe --zookeeper 192.168.0.128:2181 --topic houge

6、发送消息

sh bin/kafka-console-producer.sh --broker-list 192.168.0.128:9092 --topic houge
>
>
>

 

7、消费消息

 

sh bin/kafka-console-consumer.sh --zookeeper 192.168.0.128:2181 --topic houge   --from-beginning

 

<style></style>