一、安装
-
下载kafka,下载地址,只是使用的话下载 Binary 版本就行。
-
解压
tar -xzf kafka_2.12-2.6.1.tgz -C /data/
-C : 指定解压目录
-
需要安装并且启动 Zookeeper
-
进入Kafka目录,启动kafka,启动后日志参考下图
cd /data/kafa/
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &
- 停止kafka
bin/kafka-server-stop.sh
如果你以后台方式启动 Kafka,并且在启动时使用了 nohup
:
- 使用 ps 命令查找 Kafka 进程的 PID:
ps aux | grep kafka
- 使用 kill 命令停止 Kafka 进程:
kill -TERM <Kafka-PID>
请确保在停止 Kafka 之前,你已经停止了任何依赖于 Kafka 的其他服务,例如 Zookeeper(如果你在使用的话)
二、测试
- 进入Kafka目录,创建Topic
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
- 消费者测试
bin/kafka-console-consumer.sh --topic test-topic --bootstrap-server localhost:9092 --from-beginning
文章来源:https://www.toymoban.com/news/detail-797074.html
- 验证消息传递
在生产者终端中输入一些消息后,你应该能够在消费者终端中看到这些消息。这表明 Kafka 成功启动,并且生产者和消费者能够正常工作。文章来源地址https://www.toymoban.com/news/detail-797074.html
到了这里,关于Linux 安装 Apache Kafka的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!