社区微信群开通啦,扫一扫抢先加入社区官方微信群
社区微信群
kafka_2.12-2.5.0.taz
放到/root
目录下,并解压到新建的一个目录中[root@k8s-master ~]# cd /usr/local/zookeeper/apache-zookeeper-3.6.1-bin/bin/
[root@k8s-master bin]# ./zkServer.sh start
[root@k8s-master bin]# cd /usr/local
[root@k8s-master local]# mkdir kafka
[root@k8s-master local]# cd kafka/
[root@k8s-master kafka]# tar -zxvf /root/kafka_2.12-2.5.0.tgz -C ./
[root@k8s-master kafka_2.12-2.5.0]# mkdir logs
[root@k8s-master kafka_2.12-2.5.0]# cd config/
[root@k8s-master config]# vim server.properties
log.dirs=/usr/local/kafka/kafka_2.12-2.5.0/logs
-daemon
参数即可。[root@k8s-master config]# cd ..
[root@k8s-master kafka_2.12-2.5.0]# ./bin/kafka-server-start.sh ./config/server.properties
ruigege
的topic
,创建完成后,使用命令来列出目前已经有的topic
列表[root@k8s-master kafka_2.12-2.5.0]# ./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic ruigege
[root@k8s-master kafka_2.12-2.5.0]# ./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
[root@k8s-master kafka_2.12-2.5.0]# ./bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic ruigege
[root@k8s-master kafka_2.12-2.5.0]# ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic ruigege
[root@k8s-master ~]# mkdir project
[root@k8s-master ~]# cd project/
[root@k8s-master project]# git clone https://gitee.com/y_project/RuoYi-Vue.git
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!