step1 压缩包 kafka_2.9.2-0.8.1.1.czj.zip

 

step2：解压

unzip kafka_2.9.2-0.8.1.1.czj.zip

进入kafka_2.9.2-0.8.1.1： （以后执行命令在此路径下）

cd kafka_2.9.2-0.8.1.1

修改配置文件config/server.properties：

vim config/server.properties

属性：

broker.id=0 （随便）

host.name=hadoop03 （自己的主机 也可以是ip地址）

zookeeper.connect=hadoop03:2181 （自己的主机 也可以是ip地址，注意要统一）

 

step3: 确保有执行权限

chmod +x sbin/*

chmod +x bin/*

 

Step5：启动kafka服务

sbin/start-kafka.sh

查看是否启动： jsp -ls

启动成功会出现 kafka字样

 

tep6.创建topic主题：

bin/kafka-topics.sh --create --zookeeper hadoop03:2181 --replication-factor 1 --partitions 1 --topic mytopic （hadoop03 主机名 mytopic 主题名）

启动consumer

bin/kafka-console-consumer.sh --zookeeper hadoop03:2181 --topic mytopic

启动productor

bin/kafka-console-producer.sh --broker-list hadoop03:9092 --topic mytopic

 

在productor端输入，看consumer端的输出。