以下是在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
。