在Ubuntu上部署Kafka的步骤如下:
首先,确保系统上安装了Java运行环境。可以使用以下命令安装OpenJDK 8:
sudo apt update
sudo apt install openjdk-8-jdk
安装完成后,验证Java是否安装成功:
java -version
访问Apache Kafka官网下载最新版本的Kafka。以下是一个示例,使用Kafka 3.5.2版本:
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
解压下载的压缩包:
tar -xzvf kafka_2.12-3.5.2.tgz
将解压后的目录移动到合适的位置,例如/opt/kafka:
sudo mv kafka_2.12-3.5.2 /opt/kafka
进入Kafka目录并编辑server.properties
文件,配置监听端口和日志目录等。以下是一个示例配置:
cd /opt/kafka
sudo vi config/server.properties
需要修改的配置项包括:
broker.id
: 默认值为-1,只有大于等于0的时候,才会正常启动。listeners
: 当前Kafka的端口,例如9092。host.name
: 单机可直接用localhost。log.dirs
: 保存日志的地方,需要新建一个文件夹,例如/home/XXX/kafka_2.13-2.8.0/logs。zookeeper.connect
: Zookeeper的连接IP和端口,例如localhost:2181。在Kafka目录下,启动Zookeeper服务:
sudo bin/zookeeper-server-start.sh config/zookeeper.properties
启动Kafka服务:
sudo bin/kafka-server-start.sh config/server.properties
创建一个主题以验证安装是否成功:
sudo bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看主题列表:
sudo bin/kafka-topics.sh --list --zookeeper localhost:2181
创建生产者:
sudo bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
在出现的提示符后输入消息内容并按回车发送。
消费消息:
sudo bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
现在你可以看到刚才产生的消息。
以上步骤应该可以帮助你在Ubuntu系统上成功安装并运行Apache Kafka。如果有任何问题,请参考官方文档或相关社区资源进行排查。