Products
GG网络技术分享 2025-11-12 11:42 6
根据您给的文档内容,
系统要求

安装Java周围
bash
sudo yum install java-1.8.0-openjdk.x86_64
bash
java -version
bash
wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.8.0/kafka_2.8.0-0.11.0.0.tgz
tar -xzf kafka_2.8.0-0.11.0.0.tgz
mv kafka_2.8.0-0.11.0.0 /usr/local/kafka
server.properties
/usr/local/kafka/config/server.properties文件,配置如下参数:
broker.id独一个标识Kafka服务器的ID。listeners监听的地址和端口。log.dirs日志存储目录。启动Zookeeper服务
bash
sudo bin/zookeeper-server-start.sh config/zookeeper.properties
启动Kafka服务
bash
sudo bin/kafka-server-start.sh config/server.properties
bash
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
启动生产者
bash
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
启动消费者
bash
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
这样,您就在Linux系统上成功安装和配置了Kafka。您Neng用Kafka给的工具进行生产、消费消息以及进行其他相关的操作。
Demand feedback