安装java17
JAVA_HOME=/usr/java/jdk-17.0.4.1
PATH=$JAVA_HOME/bin:$PATH
CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:/usr/java/apache-maven-3.9.9/bin
export JAVA_HOME
export PATH
export CLASSPATH
wget https :// dlcdn.apache.org/kafka/4.0.0/kafka_2.13-4.0.0.tgz
tar -xzf kafka_2.13-4.0.0.tgz
cd kafka_2.13-4.0.0
KAFKA_CLUSTER_ID="$(bin/kafka-storage.sh random-uuid)"
bin/kafka-storage.sh format --standalone -t $KAFKA_CLUSTER_ID -c config/server.properties
创建topic
bin/kafka-topics.sh --create --topic test01 --bootstrap-server localhost:9092
查看topic
bin/kafka-topics.sh --describe --topic test01 --bootstrap-server localhost:9092
生产
bin/kafka-console-producer.sh --topic test01 --bootstrap-server localhost:9092
消费
bin/kafka-console-consumer.sh --topic test01 --from-beginning --bootstrap-server localhost:9092
