ubuntu

如何快速配置ubuntu中的kafka

小樊
44
2025-08-10 07:27:03
栏目: 智能运维

以下是在Ubuntu上快速配置Kafka的步骤:

  1. 安装Java:Kafka依赖Java,用命令sudo apt updatesudo apt install openjdk-11-jdk安装OpenJDK 11,安装后用java -version验证。
  2. 下载并解压Kafka:从官网下载,如wget https://downloads.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz,然后解压到指定目录,如/usr/local,用tar -xzf kafka_2.13-3.5.0.tgz,并重命名为kafka
  3. 配置环境变量:在~/.bashrc中添加export KAFKA_HOME=/usr/local/kafkaexport PATH=$KAFKA_HOME/bin:$PATH,用source ~/.bashrc使配置生效。
  4. 启动Zookeeper:Kafka依赖Zookeeper,进入Kafka目录,执行bin/zookeeper-server-start.sh config/zookeeper.properties &启动,用jps查看进程,出现QuorumPeerMain即成功。
  5. 启动Kafka:在另一个终端,执行bin/kafka-server-start.sh config/server.properties &启动Kafka。
  6. 创建Topic并测试:用bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test创建主题,再用生产者和消费者命令测试,如bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testbin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

0
看了该问题的人还看了