Products
GG网络技术分享 2025-11-13 04:18 2
根据您给的文档内容,
由于Kafka是用Java编写的,所以呢先说说需要安装Java周围。

bash
sudo apt update
sudo apt install default-jre
从Apache Kafka官网下载Zui新鲜版本的Kafka。
bash
wget https://www.apache.org/dist/kafka/./kafka_2.-..tgz
tar -xvzf kafka_2.-..tgz
mv kafka_2.-.. kafka
在/opt目录下创建Kafka的数据目录和日志目录。
bash
sudo mkdir /opt/kafka
sudo mkdir /opt/kafka/data
sudo mkdir /opt/kafka/logs
将解压后的Kafka目录移动到/opt/kafka,并修改配置文件。
bash
sudo mv kafka /opt/kafka
cd /opt/kafka/kafka_2.-..
sudo vi config/server.properties
在server.properties文件中, 配置以下参数:
log.dirs=/opt/kafka/logslog4j.loggers.rootLogger=INFO,consolezookeeper.connect=localhost:2181ZooKeeper是Kafka的基础服务,需要先启动ZooKeeper。
bash
bin/zookeeper-server-start.sh config/zookeeper.properties
启动Kafka服务。
创建一个名为my-topic的主题。
bash
bin/kafka-topics.sh --create --topic my-topic --zookeeper localhost:2181 --partitions 1 --replication-factor 1
启动一个生产者,向my-topic主题发送消息。
bash
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic
启动一个消费者,从my-topic主题接收消息。
bash
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning
以上步骤将帮您在Ubuntu系统上成功安装和配置Kafka。
Demand feedback