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

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

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。