1.

Apache Kafka是一个分布式流处理平台，用于构建实时数据管道和流应用程序。在CentOS上安装Kafka能让你利用其有力巨大的数据处理能力。本文将详细介绍怎么在CentOS上安装Kafka的步骤。

2. 前提条件

2.1 系统要求

确保你的CentOS系统满足以下要求：

• 操作系统：CentOS 7或更高大版本
• 内存：至少许1GB
• 磁盘地方：至少许1GB

2.2 安装Java

Kafka是用Java编写的，所以呢需要安装Java开发周围。

sudo yum install java-1.8.0-openjdk-devel -y
java -version

3. 下载Kafka

从Apache Kafka官网下载最新鲜版本的Kafka压缩包。比方说下载kafka_2.13-3.8.0.tgz。

sudo wget https://www.apache.org/dyn/closer.cgi?path=/kafka/3.8.0/kafka_2.13-3.8.0.tgz

4. 解压Kafka

将下载的压缩包解压到指定目录，比方说/opt。

sudo tar -xzf kafka_2.13-3.8.0.tgz -C /opt

5. 配置Kafka

进入Kafka目录并进行基本配置。

cd /opt/kafka_2.13-3.8.0
sudo vi config/server.properties

• broker.id：独一个标识符， 确保在集群中独一个
• log.dirs：日志存储目录
• log4j.properties：日志配置文件

6. 启动Kafka服务

sudo /opt/kafka_2.13-3.8.0/bin/kafka-server-start.sh config/server.properties

7. 验证安装

用以下命令验证Kafka服务是不是正在运行：

sudo /opt/kafka_2.13-3.8.0/bin/kafka-topics.sh --list --bootstrap-server localhost:9092

如果一切正常，你得能看到一个名为__consumer_groups的主题。

8. 测试连接

创建一个名为test-topic的主题：

sudo /opt/kafka_2.13-3.8.0/bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

发送消息：

echo "Hello, Kafka!" | sudo /opt/kafka_2.13-3.8.0/bin/kafka-console-produce.sh --topic test-topic --bootstrap-server localhost:9092

消费消息：

sudo /opt/kafka_2.13-3.8.0/bin/kafka-console-consume.sh --topic test-topic --from-beginning --bootstrap-server localhost:9092

9.

以上步骤得能帮你在CentOS上成功安装并运行Kafka。Kafka是一个功能有力巨大的工具，能用于构建高大性能的实时数据管道和应用程序。

---