centos7安装Kafka单节点环境部署二-安装与配置kafka

在CentOS 7上安装和配置Kafka单节点的步骤如下：

1. 安装Java环境

   Kafka依赖Java，确保系统已安装Java。

sudo yum install java-1.8.0-openjdk

2. 下载并解压Kafka

   从官网下载Kafka压缩包，解压到指定目录。

wget https://downloads.apache.org/kafka/2.7.0/kafka_2.13-2.7.0.tgz
sudo tar -xzf kafka_2.13-2.7.0.tgz -C /opt

3. 配置Kafka

   编辑Kafka配置文件config/server.properties。

sudo vi /opt/kafka_2.13-2.7.0/config/server.properties

修改或确保以下配置项：

broker.id=1
listeners=PLAINTEXT://:9092
log.dirs=/var/local/kafka
zookeeper.connect=localhost:2181

4. 启动ZooKeeper和Kafka

   Kafka使用ZooKeeper，所以首先启动ZooKeeper。

sudo /opt/kafka_2.13-2.7.0/bin/zookeeper-server-start.sh /opt/kafka_2.13-2.7.0/config/zookeeper.properties

然后启动Kafka服务器。

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

5. 验证安装

   创建一个测试topic，然后生产和消费消息。

# 创建topic
sudo /opt/kafka_2.13-2.7.0/bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
 
# 生产消息
sudo /opt/kafka_2.13-2.7.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
 
# 新开一个终端消费消息
sudo /opt/kafka_2.13-2.7.0/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

如果在生产者端输入文本并回车后，可以在消费者端看到相同的文本，表示Kafka安装成功。