Huawei Cloud EulerOS
Huawei Cloud EulerOS
- 最新动态
- 服务公告
- 产品介绍
- 用户指南
-
常见问题
- CentOS Linux停止维护后如何应对?
- 华为云针对CentOS EOL有没有迁移方案?
- 如何安装mlnx驱动?
- 如何开启HCE操作系统的SELinux功能?
- 迁移系统后,如何更改控制台操作系统名称?
- Huawei Cloud EulerOS、openEuler和EulerOS镜像的主要区别是什么?
- 如何打开内核wireguard模块以及安装wireguard-tools?
- 如何将docker工具的用户凭证保存方式配置成与社区一致?
- OOM相关参数配置与原因排查
- IPVS报错问题说明
- 中文环境执行sulogin命令终端显示乱码说明
- ECS开启IPv6后,HCE系统内无法获取到IPv6地址
- 如何设置自动注销时间TMOUT?
- 最佳实践
- 文档下载
- 通用参考
链接复制成功!
安装Kafka
简介
Kafka是一个拥有高吞吐、可持久化、可水平扩展,支持流式数据处理等多种特性的分布式消息流处理中间件,采用分布式消息发布与订阅机制,在日志收集、流式数据传输、在线/离线系统分析、实时监控等领域有广泛的应用。
本教程介绍如何在HCE 2.0上安装部署Kafka。
准备工作
- 准备一台ECS,并分配公网IP或者弹性公网IP(EIP)。
- 安全组入方向已放开9092端口
操作步骤
- 安装kafka软件。
执行以下命令安装软件。
dnf install kafka
执行结束后,Kafka会被安装到/opt/kafka目录。
- 软件配置。
- 编辑“/opt/kafka/config/server.properties”文件,找到如下属性进行修改。
listeners=PLAINTEXT://<内网IP>:9092 advertised.listeners=PLAINTEXT://<公网IP>:9092
- 新建“/lib/systemd/system/zookeeper.service”文件,并输入以下内容。
[Unit] Description=Zookeeper service After=network.target [Service] Type=simple Environment="PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin" User=root Group=root ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh Restart=on-failure SuccessExitStatus=143 [Install] WantedBy=multi-user.target
- 新建“/lib/systemd/system/kafka.service”文件,并输入以下内容。
[Unit] Description=Apache Kafka server (broker) After=network.target zookeeper.service [Service] Type=simple Environment="PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin" User=root Group=root ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties ExecStop=/opt/kafka/bin/kafka-server-stop.sh Restart=on-failure SuccessExitStatus=143 [Install] WantedBy=multi-user.target
- 依次输入以下命令,启动Kafka和Zookeeper服务。
systemctl daemon-reload systemctl start zookeeper systemctl start kafka
- 编辑“/opt/kafka/config/server.properties”文件,找到如下属性进行修改。
- 验证。
- 使用以下命令创建Topic。
/opt/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
- 使用以下命令查看刚才创建的Topic。
/opt/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181
如果部署正常,则会输出test。
- 使用以下命令创建Topic。
以上相关配置仅用于测试,业务环境请谨慎使用。