kafka centos 单点配置

kafka&zookeeper

环境 centos64虚拟机

单节点单broker

1 下载kafka

2 解压并进入kafka目录

3 修改配置文件
vim config/server.properties 如修改brokerId和端口

4 启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties

5 启动kafka
bin/kafka-server-start.sh config/server.properties

6 查看topic
bin/kafka-topics.sh --list --zookeeper localhost:2181

7 启动producer生产者
bin/kafka-console-producer.sh --broker-list localhost:8080 --topic test

8 启动consumer消费者

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

如上 在7的生产者中发送消息可以在8的消费者中进行消费。

单节点多broker
copy两份kafka安装文件 分别命名为kafka2 kafka3。
分为进入两个文件目录。修改配置文件
vim config/server.properties
修改brokerId和端口三个broker各不相同；
修改log地址分别不同。

分别如上7 启动broker2 broker3 可以在1 2 3 作为生产者 消费者将可以同时收到三个生产者的消息。