在Ubuntu上安装Apache Kafka的步骤如下:
更新系统包列表
sudo apt update
安装Snap(如果尚未安装)
sudo apt install snapd
启用Snap商店
sudo snap refresh
搜索并安装Kafka
sudo snap find kafka
sudo snap install kafka --classic
启动Kafka服务
sudo systemctl start kafka
设置Kafka服务开机自启
sudo systemctl enable kafka
检查Kafka服务状态
sudo systemctl status kafka
下载Kafka 访问Apache Kafka官方下载页面,选择适合你系统的版本进行下载。例如,下载最新版本的Kafka:
wget https://archive.apache.org/dist/kafka/3.2.0/kafka_2.13-3.2.0.tgz
解压文件
tar -xzf kafka_2.13-3.2.0.tgz
cd kafka_2.13-3.2.0
启动Zookeeper Kafka依赖于Zookeeper,首先启动Zookeeper:
bin/zookeeper-server-start.sh config/zookeeper.properties
启动Kafka服务器 在另一个终端窗口中启动Kafka服务器:
bin/kafka-server-start.sh config/server.properties
创建一个测试主题
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
查看所有主题
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
生产消息到主题
bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
然后在终端输入消息并按回车键发送。
消费消息
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092
config/server.properties
和config/zookeeper.properties
文件中的配置项。num.partitions
、log.retention.hours
等。通过以上步骤,你应该能够在Ubuntu系统上成功安装并运行Apache Kafka。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:Kafka在Ubuntu上如何安装