以下是在Ubuntu上快速配置Kafka的步骤:
sudo apt update和sudo apt install openjdk-11-jdk安装OpenJDK 11,安装后用java -version验证。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。~/.bashrc中添加export KAFKA_HOME=/usr/local/kafka和export PATH=$KAFKA_HOME/bin:$PATH,用source ~/.bashrc使配置生效。bin/zookeeper-server-start.sh config/zookeeper.properties &启动,用jps查看进程,出现QuorumPeerMain即成功。bin/kafka-server-start.sh config/server.properties &启动Kafka。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 test和bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning。