一、准备工作
centos7虚拟机，finalShell等ssh工具
二、安装配置
说明：
1、jdk配置：进入 vi /etc/profile， 配置后 source /etc/profile已使配置生效
export JAVA_HOME=/usr/local/jdk1.8.0_291 export JRE_HOME=${JAVA_HOME}/jre export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib:$CLASSPATH export JAVA_PATH=${JAVA_HOME}/bin:${JRE_HOME}/bin export PATH=$PATH:${JAVA_PATH}
2、zookeeper配置：复制zoo_sample.cfg 到zoo.cfg
进入zoo.cfg，其他不动，添加 admin.serverPort=2190 默认管理台端口是8080，这里为了将来部署不占用8080端口，另写端口
同样，将zookeeper路径加入export;注意 mkdir data 以存放zookeeper运行数据。
启动服务：
zkServer.sh start
3、配置kafka：需要下载 .tgz 不要下载-src.tgz【src是源码包，后续启动不成功】；
配置文件 vi config/server.properties。默认已经有一个zookeeper配置，集群的话这里配置多个，逗号隔开
同样加入export，并使生效
启动kafka 后面带& 可以后台运行
kafka-server-start.sh config/server.properties
创建测试topic
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看topic
kafka-topics.sh --list --zookeeper localhost:2181
生产消息 提示输入消息内容 如hello
kafka-console-producer.sh --broker-list localhost:9092 --topic test
消费消息
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
原文：https://www.cnblogs.com/x-jingxin/p/14991829.html