在Linux上部署Kafka并进行服务管理,可以通过以下步骤实现:
Kafka是用Java编写的,因此首先需要安装Java运行环境。可以使用以下命令安装OpenJDK 8:
sudo apt update sudo apt install openjdk-8-jdk 验证Java安装成功:
java -version 从Apache Kafka官网下载最新版本的Kafka,然后解压到指定目录。例如:
wget https://downloads.apache.org/kafka/3.5.0/kafka_2.12-3.5.0.tgz tar -xzf kafka_2.12-3.5.0.tgz -C /opt 编辑/etc/profile文件,添加Kafka和Zookeeper的路径:
export KAFKA_HOME=/opt/kafka_2.12-3.5.0 export PATH=$PATH:$KAFKA_HOME/bin 进入Kafka解压目录的bin目录,执行启动命令:
./zookeeper-server-start.sh config/zookeeper.properties 同样在Kafka的bin目录下,执行启动命令:
./kafka-server-start.sh config/server.properties 创建主题:
kafka-topics.sh --create --topic my-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 8 查看主题列表:
kafka-topics.sh --list --bootstrap-server localhost:9092 消费消息:
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic 通过上述步骤,你可以在Linux上成功部署Kafka并进行服务管理。如果需要更高级的管理功能,可以考虑使用Kafka Manager或Confluent Control Center等工具。