在Debian上部署Kafka的流程如下:
sudo apt update
sudo apt install openjdk-8-jdk
java -version
wget
命令在線下載:wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
tar -zvxf kafka_2.12-3.5.2.tgz
/etc/profile
文件,在文件末尾添加以下兩行命令以配置全局環境變量:export KAFKA_HOME=/path/to/your/kafka_2.12-3.5.2
export PATH=$PATH:$KAFKA_HOME/bin
/path/to/your/kafka_2.12-3.5.2
替換為實際的Kafka安裝路徑。cd $KAFKA_HOME
./bin/zookeeper-server-start.sh config/zookeeper.properties
./bin/kafka-server-start.sh config/server.properties
./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果看到列出的topic,則表示Kafka安裝成功。
./bin/kafka-topics.sh --create --topic my-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning
以上就是在Debian上部署Kafka的基本流程。根據實際需求,可能還需要進行更多的配置和優化。