centos kafka安装？centos7.6安装教程

大家好，今天小编来为大家解答centos kafka安装这个问题，centos7.6安装教程很多人还不知道，现在让我们一起来看看吧！

centos7中安装zookpeer和kafka(单机)

在CentOS 7服务器上安装Zookeeper和Kafka（单机模式）的过程如下：

首先，从官方网站下载Zookeeper和Kafka的压缩包。你可以选择官方提供的版本，或者从可信的第三方资源下载。

将下载的压缩包解压到服务器上的特定目录中，并创建一个用于存放压缩包的文件夹。例如：

新建一个名为`test`的文件夹。

安装Zookeeper的步骤如下：

1.将解压后的Zookeeper文件夹重命名为`zk`，并移动到`/usr/local/`目录下。

2.切换到`/usr/local/zk/conf/`目录下，复制一个`zoo_sample.cfg`文件并将其重命名为`zoo.cfg`。

3.使用文本编辑器（如vi）打开`zoo.cfg`文件，并修改`datadir`参数为`/usr/local/zk/data`。

4.在`zk`目录下创建`data`文件夹。

5.通过`/etc/profile`文件配置环境变量。添加`java_home`和`zk_home`的路径，将`zk`的`bin`目录路径添加到`path`中。

6.使环境变量生效，执行`source/etc/profile`。

7.进入`/usr/local/zk/bin/`目录，启动Zookeeper服务器：`zkServer.sh start`。

检查Zookeeper状态，确保其显示为`standalone`。

执行`zkServer.sh start`、`zkServer.sh stop`、`zkServer.sh restart`和`zkServer.sh status`，分别启动、停止、重启和查看当前节点状态。

接下来安装Kafka：

1.将Kafka压缩包解压到服务器上。

2.将解压后的Kafka文件夹移动到`/usr/local/`目录下。

3.切换到`/usr/local/kafka/config/`目录下，使用文本编辑器修改`server.properties`文件。

4.将`log.dirs`参数设置为`/usr/local/kafka/data/kafka-logs`，将`connect`中的`localhost`替换为服务器IP地址，修改`advertised.listeners`参数为`PLAINTEXT:// xx.xx.xx.xxx:9092`（`xx`代表你的服务器IP）。

5.常规模式下启动Kafka：`./kafka-server-start.sh../config/server.properties&`。

关闭Kafka：`./kafka-server-stop.sh`。

使用进程守护模式启动Kafka：`nohup./kafka-server-start.sh config/server.properties>/dev/null 2>&1&`。

如果在安装过程中遇到错误，可以尝试调整Kafka的启动内存大小，修改`KAFKA_HEAP_OPTS`环境变量为`-Xmx512M-Xms512M`。

创建一个Kafka主题：在Kafka的`bin`目录下执行`./kafka-topics.sh--create--zookeeper 127.0.0.1:2181--partitions 1--replication-factor 1--topic test`。

使用生产者向Kafka发送消息：`./kafka-console-producer.sh--broker-list 127.0.0.1:9092--topic test`。

使用消费者消费消息：在另一个终端窗口中执行`./kafka-console-consumer.sh--broker-list 127.0.0.1:9092--topic test`。

如果在使用消费者时遇到问题，可以尝试使用`./kafka-console-consumer.sh--bootstrap-server 127.0.0.1:9092--topic test`。

在CentOS 7中关闭防火墙：执行`systemctl stop firewalld.service`。

最后，确保将Kafka的`9092`端口添加到安全组中，以允许外部访问。

【强烈推荐一款吊炸天的 Kafka 图形化工具 Eagle】

Kafka作为一种流行的消息中间件，在业界得到了广泛应用。根据官方数据，成千上万的公司在使用Kafka。本文将围绕Kafka的安装、可视化工具以及与SpringBoot的结合使用三个方面进行探讨，帮助读者快速掌握这个强大的消息中间件。

Kafka是由LinkedIn公司开发的开源分布式消息流平台，采用Scala和Java编写。它为实时数据处理提供了一个统一、高吞吐、低延迟的平台，其核心是基于发布订阅模式的消息引擎系统。

在Linux环境下安装Kafka时，我们选择CentOS 7.6作为安装环境，并未采用Docker进行安装部署。这是因为直接安装的方式更加简单（主要是官方没有提供Docker镜像）。

接下来，我们将使用命令行操作Kafka，熟悉其使用方法。不过，使用命令行操作Kafka可能会有些麻烦，因此我们尝试使用可视化工具kafka-eagle来操作。

在开始之前，我们需要确保CentOS已经安装了完整版的JDK。对于CentOS系统，默认情况下没有安装完整版的JDK，需要手动进行安装。

在SpringBoot中操作Kafka也非常简单。例如，Kafka的消息模式只有Topic，没有队列。

通过本文的实践，读者基本可以入门Kafka。安装、可视化工具、结合SpringBoot等操作，都是学习Kafka的必经之路。

kafka之二:手把手教你安装kafka2.8.0(绝对实用)

深入学习kafka，本文将引导您一步一步安装kafka 2.8.0版本，确保您的操作环境支持zookeeper，如需详细了解zookeeper安装，请查阅《zookeeper之二：zookeeper3.7.0安装完全指南（绝对实用）》。建议使用单独的zookeeper环境以获得更好的独立性与稳定性。

首先，请访问kafka的官方下载页面kafka.apache.org/，获取最新版本的二进制安装包。我已下载Scala 2.12版本的kafka安装包，接下来请按照以下步骤操作。

1.**安装步骤**

1.1**环境准备**：确保您的操作系统为CentOS 7（64位），已安装JDK 1.8版本，同时zookeeper已安装，版本为3.7，并配置环境变量指向zookeeper的地址，如127.0.0.1:2182、127.0.0.1:2183、127.0.0.1:2184。

1.2**修改配置文件**：解压kafka安装包后，bin目录存放启动脚本，config目录存放配置文件，libs目录存放启动依赖，logs目录存放运行日志。重点修改config/server.properties文件，配置broker.id、listeners、num.partitions、log.dirs、log.retention.hours、default.replication.factor以及zookeeper.connect。

1.3**启动单机版**：在解压目录执行启动命令，查看日志确认启动成功。若希望后台运行，使用-daemon参数启动。

1.4**启动集群版**：在至少3台虚拟机上启动集群，确保zookeeper和JDK环境配置一致。配置文件放置在config/cluster文件夹内，每个配置文件对应一台虚拟机，确保日志路径预设。

1.5**验证启动**：通过jps命令检查进程，或使用kafka自带客户端创建topic，验证集群状态。

按照上述步骤，您将成功安装并启动kafka 2.8.0版本。对于更多深入用法与优化，请参考相关技术博客与指南。