在CentOS 7上安装和配置Kafka单节点的步骤如下:
安装Java环境
Kafka依赖Java,确保系统已安装Java。
sudo yum install java-1.8.0-openjdk
下载并解压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
配置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
启动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
验证安装
创建一个测试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安装成功。