Kafka安装部署

要在Ubuntu系统上安装Apache Kafka，你可以按照以下步骤进行：

1. 安装Java运行环境：Kafka需要Java环境，因此首先需要安装Java。可以通过以下命令安装OpenJDK 11：

   sudo apt update
   sudo apt install openjdk-11-jdk -y
   

   然后检查Java版本：

   java -version
   

2. 下载并解压Kafka：从Apache Kafka的官方网站下载Kafka的压缩包，并解压到指定目录。例如：

   wget https://downloads.apache.org/kafka/3.5.1/kafka_2.13-3.5.1.tgz
   tar xvf kafka_2.13-3.5.1.tgz
   sudo mv kafka_2.13-3.5.1 /usr/local/kafka
   

3. 创建Kafka和ZooKeeper系统服务：创建systemd服务文件来管理Kafka和ZooKeeper服务。

4. 启动服务：启动ZooKeeper和Kafka服务。

   sudo systemctl start zookeeper
   sudo systemctl start kafka
   

5. 创建Kafka主题：创建一个Kafka主题用于消息传输。

   cd /usr/local/kafka
   bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic sampleTopic
   

6. 发送和接收消息：使用Kafka的命令行工具发送和接收消息。

   bin/kafka-console-producer.sh --broker-list localhost:9092 --topic sampleTopic
   bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sampleTopic --from-beginning
   

以上步骤提供了一个基本的指南来安装和开始使用Kafka。确保在安装过程中，你已经满足了所有环境要求，包括安装了正确版本的Java和ZooKeeper。