在Ubuntu系统中配置Apache Kafka涉及几个步骤，包括安装Java环境、下载和解压Kafka、配置Kafka以及启动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
解压下载的tgz文件：
tar -xzvf kafka_2.12-3.5.2.tgz
进入解压后的Kafka目录：
cd kafka_2.12-3.5.2
Kafka依赖于Zookeeper，因此需要配置Zookeeper。首先，创建Zookeeper的数据目录：
mkdir -p /tmp/zookeeper
编辑Zookeeper的配置文件zoo.cfg：
nano /tmp/zookeeper/conf/zoo.cfg
添加或修改以下配置项：
tickTime=2000
dataDir=/tmp/zookeeper
clientPort=2181
保存并退出编辑器。
接下来，配置Kafka Broker。编辑Kafka的配置文件server.properties：
nano config/server.properties
添加或修改以下配置项：
listeners=PLAINTEXT://your_server_ip:9092
log.dirs=/tmp/kafka
zookeeper.connect=localhost:2181
将your_server_ip替换为你的服务器IP地址。
首先，启动Zookeeper：
/tmp/zookeeper/bin/zookeeper-server-start.sh config/zoo.cfg
然后，启动Kafka：
./bin/kafka-server-start.sh config/server.properties
启动Kafka后，可以使用以下命令来验证是否成功启动：
netstat -an | grep 9092
你应该能看到类似以下的输出，表示Kafka正在监听9092端口：
tcp 0 0 0.0.0.0:9092 0.0.0.0:* LISTEN
使用以下命令创建一个新的Topic：
./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
启动一个Kafka生产者来发送消息：
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
输入消息并按Enter键发送。
启动一个Kafka消费者来接收消息：
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
你应该能看到在生产者终端输入的消息。
为了方便使用Kafka命令，可以将Kafka的bin目录添加到系统的PATH环境变量中。编辑~/.bashrc或~/.profile文件：
export KAFKA_HOME=/path/to/kafka_2.12-3.5.2
export PATH=$PATH:$KAFKA_HOME/bin
保存并退出编辑器，然后刷新配置：
source ~/.bashrc
现在，你可以直接运行Kafka命令而无需指定完整路径。
通过以上步骤，你应该能够在Ubuntu系统上成功配置和运行Apache Kafka。如果有任何问题，请检查日志文件以获取更多信息。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
推荐阅读：Kafka配置Ubuntu系统资源
