kafka初识

一、准备工作

centos7虚拟机，finalShell等ssh工具

二、安装配置

参考：centos7安装和使用kafka

说明：

　　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