以下是如何在Debian上安装Apache Kafka的详细步骤：
1. 系统包更新
首先，确保你的系统包是最新的，这有助于保持系统的稳定性和安全性：
sudo apt updatesudo apt upgrade -y2. 安装Java（Kafka依赖Java）
由于Kafka需要Java环境，你可以选择安装OpenJDK来满足这一需求：
sudo apt install openjdk-11-jdk -y安装完成后，验证Java是否正确安装：
java -version3. 下载Kafka
从Apache Kafka官方网站下载最新的Kafka版本。你可以通过wget命令来完成下载：
wget https://downloads.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz记得根据最新的稳定版本更新URL中的版本号。
4. 解压Kafka
下载完成后，解压Kafka文件：
tar -xzf kafka_2.13-3.3.1.tgzcd kafka_2.13-3.3.15. 启动Zookeeper
Kafka依赖于Zookeeper进行集群管理，首先启动Zookeeper服务器：
bin/zookeeper-server-start.sh config/zookeeper.properties6. 启动Kafka服务器
在另一个终端窗口中，启动Kafka服务器：
bin/kafka-server-start.sh config/server.properties7. 创建Topic
创建一个名为test-topic的Topic：
如知AI笔记
如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型
27 查看详情
bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 18. 验证Topic创建
列出所有Topic以确认test-topic是否已成功创建：
bin/kafka-topics.sh --list --bootstrap-server localhost:90929. 生产者和消费者测试
你可以使用Kafka自带的工具来测试生产者和消费者。
生产者测试
向test-topic发送一条消息：
bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092在提示符下输入消息并按回车键发送。
消费者测试
从test-topic消费消息：
bin/kafka-console-consumer.sh --topic test-topic --from-beginning --bootstrap-server localhost:9092你应该能看到之前发送的消息。
10. 停止Kafka和Zookeeper
完成测试后，停止Kafka和Zookeeper服务器：
# 停止Kafka服务器bin/kafka-server-stop.sh停止Zookeeper服务器
如果Zookeeper配置正确，可以使用以下命令
bin/zookeeper-server-stop.sh
注意事项
确保防火墙允许9092端口的流量。在生产环境中，建议使用多个Broker和更高的副本因子来确保高可用性和容错性。根据需求调整配置文件server.properties和zookeeper.properties。
通过以上步骤，你应该能够在Debian上成功安装并运行Apache Kafka。
以上就是如何在Debian上安装Kafka的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/504409.html
微信扫一扫 
支付宝扫一扫 
