Kafka消息队列Linux上怎么用

以下是在Linux上使用Kafka消息队列的步骤：

1. 安装Java环境：Kafka依赖Java，根据系统类型使用相应命令安装OpenJDK，如Ubuntu/Debian系统用sudo apt update和sudo apt install openjdk-11-jdk，CentOS/RHEL系统用sudo yum install java-11-openjdk-devel，安装后用java -version验证。
2. 下载并解压Kafka：从官网下载最新稳定版本，如wget https://downloads.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz，然后解压，tar -xzf kafka_2.13-3.5.0.tgz。
3. 配置Kafka：
   • 若使用内置Zookeeper，可直接修改config/server.properties，设置broker.id、listeners、log.dirs、zookeeper.connect等参数。
   • 若使用独立Zookeeper，需分别配置config/zookeeper.properties和config/server.properties。
4. 启动服务：先启动Zookeeper，bin/zookeeper-server-start.sh config/zookeeper.properties，再启动Kafka，bin/kafka-server-start.sh config/server.properties。
5. 创建Topic：使用bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1命令创建。
6. 测试消息收发：启动生产者bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092，在新终端启动消费者bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092。