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。