伪分布式中kafka中已经集成了zookeeper
1.下载kafka
kafka_2.11-0.10.0.1
2.解压kafka
tar -zxvf kafka_2.11-0.10.0.1.tgz
3.移动到下面文件夹
/home/software/kafka_2.11-0.10.0.1
4.配置文件
vi /etc/profile
export KAFKA_HOME=/home/software/kafka_2.11-0.10.0.1
export PATH=$PATH:$KAFKA_HOME/bin
source /etc/profile
5.修改zk的log地址
在kafka目录下
cd config
vim zookeeper.properties
dataDir=/home/data/zookeeper
6.启动kafka
单机模式-kafka自然集成zk
zk config路径
/home/software/kafka_2.11-0.10.0.1/config/zookeeper.properties
在kafka目录下
cd bin
(1)启动zk
nohup zookeeper-server-start.sh /home/software/kafka_2.11-0.10.0.1/config/zookeeper.properties &
(2)启动Broker
nohup kafka-server-start.sh /home/software/kafka_2.11-0.10.0.1/config/server.properties &
7.启动成功
8.准备测试
(1).创建主题
kafka-topics.sh --create --zookeeper localhost:2181 --topic mytopic --partitions 1 --replication-factor 1
--create 执行的动作
--zookeeper 主题写入位置
--topic 主题
--partitions 物理分区
--replication-factor 副本因子
(2).创建生产者
kafka-console-producer.sh --broker-list 192.168.56.102:9092,192.168.56.103:9092,192.168.56.104:9092 --topic mytopic
(3).创建消费者
kafka-console-consumer.sh --zookeeper192.168.56.101:2181 --topic mytopic
(4).发送消息