kafka环境配置

1. 下载kafka安装包，解压

sudo tar -zxvf kafka_2.12-1.0.1.tgz
sudo mv kafka_2.12-1.0.1 /usr/local/kafka

 

2. 修改配置文件

zookeeper.properties

cd kafka/config
sudo vim zookeeper.properties

dataDir=/home/hadoop/zookeeper/kafka/data/zookeeper
dataLogDir=/home/hadoop/zookeeper/kafka/log/zookeeper
clientPort=2181
maxClientCnxns=100
tickTime=2000
initLimit=10
syncLimit=5

server.properties

cd kafka/config
sudo vim server.properties

broker.id=0
port=9092
host.name=hadoop  #此处为主机名或IP地址
log.dirs=/home/hadoop/zookeeper/kafka/log/kafka/
zookeeper.connect=localhost:2181

 

三、建立启动关闭文件

    1. 建立启动文件

cd kafka
sudo vim ./kafkastart.sh

#!/bin/bash
/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties &


sleep 3

/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &

 

2. 建立关闭文件

cd kafka
sudo vim ./kafkastop.sh

#!/bin/bash
#关闭zookeeper
/usr/local/kafka/bin/zookeeper-server-stop.sh /usr/local/kafka/config/zookeeper.properties &
sleep 3 #等3秒后执行
#关闭kafka
/usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties &

 

4. 启动zookeeper     进程有三个

$ cd kafka
$ ./kafkastart.sh
hadoop@hadoop:/usr/local/zookeeper/bin$ jps
14517 Kafka
14245 QuorumPeerMain
15383 Jps

 

建立topic

hadoop@hadoop:/usr/local/kafka/bin$ ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic te
Created topic "test"

查看topic

cd /usr/local/kafka/bin
./kafka-topics.sh --list --zookeeper localhost:2181

生产消息

$ cd /usr/local/kafka/bin
$ ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
laoyang I love you!

消费消息测试

$ cd /usr/local/kafka/bin
$ ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
I'm laoyang #以前测试输入的内容
laoyang I love you!

 

5. 关闭kafka

$ cd /usr/local/kafka
$ ./kafkastop.sh