1，java环境

1.1 下载java

wget https://javadl.oracle.com/webapps/download/AutoDL?BundleId=245469_4d5417147a92418ea8b615e228bb6935

tar -xvf jre-8u311-linux-x64.tar.gz

将 java放到path当中：

source /etc/profile

验证java是否安装成功：

2，运行kafka

2.1 运行zookeeper

nohup bin/zookeeper-server-start.sh config/zookeeper.properties &

查看zookeeper是否启动成功：

2.2 运行kafka server

nohup bin/kafka-server-start.sh config/server.properties &

查看kafka server是否启动成功：

2.3 主题操作

新建主题：
bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test1 --partitions 1 --replication-factor 1

列出所有主题：

kafka_2.13-3.0.0 bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

查看某个主题：

bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic test1

2.4 生产者

bin/kafka-console-producer.sh --topic test1 --bootstrap-server localhost:9092

2.5消费者

bin/kafka-console-consumer.sh -topic test1 --bootstrap-server localhost:9092 --offset 1 --partition 0