Kafka 简略安装及测试

安装kafka

kafka 是基于 jvm 运行的，所以安装kafka 之前首先要安装 jdk，此处不单独介绍 jdk 的安装方式。

安装kafka 首先进入官网下载kafka的安装包
https://kafka.apache.org/downloads

随便选一个下载即可。

下载后解压并进入文件夹会看到 两个主要的目录: bin 和 config
执行以下命令即可启动kafka：
首先需要启动zookeeper，现在的kafka 都是自带zookeeper 的，所以不用单独再去下载 zookeeper

nohup ./bin/zookeeper-server-start.sh ./config/zookeeper.properties &

启动日志无误后再启动 kafka：

nohup ./bin/kafka-server-start.sh ./config/server.properties &

测试

查看日志没有报错后即可进行测试：
首先是启动生产者：

bin/kafka-console-producer.sh --broker-list <your ip>:9092 --topic mytest-topic

再启动消费者：

bin/kafka-console-consumer.sh --bootstrap-server <your ip>:9092 --topic mytest-topic

如果两边启动都没有问题，在 生产者中发送消息便可以再 消费者中显示输出。