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