kafka单机部署

参考官方文档：quickstart

一、准备环境

centos7、jdk8

安装过程（略），关闭防火墙

二、安装kafka

下载安装包：下载地址

  • 上传到/usr/local目录

  • 解压文件

    tar -zxvf kafka_2.12-2.8.0.tgz

  • 修改监听地址，默认127.0.0.1

    vim /usr/local/kafka_2.12-2.8.0/config

    修改如下代码，替换为自己IP地址

    listeners = PLAINTEXT://xxxx:9092

  • 启动zookeeper，这里使用了自带的zookeeper

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

  • 开启新的终端，启动kafka

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

  • 开启新的终端，创建topic

    bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server xxxx:9092

  • 查看topic

    bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server xxxx:9092

  • 往topic写消息

    bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server xxxx:9092

  • 开启新的终端，读取topic的消息

    bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server xxxx:9092
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容