要在Linux上安装Kafka,请按照以下步骤操作:
在Apache Kafka官网上下载Kafka的二进制文件。你可以从 https://kafka.apache.org/downloads 下载适合你系统的版本。
解压下载的文件。使用以下命令解压:
tar -xzf kafka_2.12-2.8.0.tgz
请将 "kafka_2.12-2.8.0.tgz" 替换为你下载的文件名。
进入解压后的Kafka目录:
cd kafka_2.12-2.8.0
配置Kafka。你需要编辑
config/server.properties
文件来配置Kafka。你可以使用任何文本编辑器打开该文件,但要以管理员身份运行编辑器。修改以下配置:listeners=PLAINTEXT://localhost:9092
这将配置Kafka监听在本地的9092端口。
启动Kafka服务器。使用以下命令启动Kafka服务器:
bin/kafka-server-start.sh config/server.properties
Kafka将在后台运行,并绑定到指定的端口。
验证Kafka是否正常运行。你可以使用以下命令创建一个测试主题,并发送一些消息:
bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1 bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092
在控制台输入一些消息,然后按Ctrl+C退出。
通过消费者消费消息,查看消息是否成功发送和接收:
bin/kafka-console-consumer.sh --topic test-topic --bootstrap-server localhost:9092 --from-beginning
你应该能够看到你之前发送的消息。
这样你就成功安装和配置了Kafka。你可以根据自己的需求进一步配置和使用Kafka。