Apache Kafka-安装步骤

Apache Kafka是一款流行的分布式消息传递系统，广泛应用于实时数据流处理、日志收集和消息队列等场景。本文将介绍如何安装和配置Apache Kafka。

步骤一：安装Java环境

首先需要安装Java环境，Kafka需要运行在Java环境下。如果您的系统中已经安装了Java环境，则可以跳过这一步。

安装Java可参考下面的命令：

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

步骤二：下载和解压Kafka

1.下载Apache Kafka的安装包

2.使用如下命令解压缩kafka压缩包：

tar -xzf kafka_2.13-2.8.0.tgz

步骤三：启动Kafka

1. 打开终端，进入kafka安装目录，启动zookeeper服务

bin/zookeeper-server-start.sh config/zookeeper.properties

2. 在同一个终端中打开一个新的Tab，进入kafka安装目录，启动kafka服务

bin/kafka-server-start.sh config/server.properties

步骤四：创建Topic

要向Kafka发送和接收消息，需要先创建一个Topic。我们可以使用以下命令创建名为test-topic的Topic：

bin/kafka-topics.sh --create --topic test-topic --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092

步骤五：生产者发送消息

1. 在同一个终端中打开一个新的Tab，进入kafka安装目录，启动生产者发送消息

bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092

2. 然后在终端中输入消息，并按回车键发送:

>hello kafka

步骤六：消费者接收消息

1. 在同一个终端中打开一个新的Tab，进入kafka安装目录，启动消费者接收消息

bin/kafka-console-consumer.sh --topic test-topic --from-beginning --bootstrap-server localhost:9092

2. 然后可以看到刚刚发送的消息

hello kafka

结论

至此，Kafka已经成功安装并运行。Kafka的运行和使用不止这些，后续我们需要了解更多操作和参数，如高可用和集群等，在实际使用中可以再进行学习。