1.Kafka启动
首先,需要启动ZooKeeper,输入命令:
bin/zookeeper-server-start.sh config/zookeeper.properties
2.启动Kafka服务器
命令:
bin/kafka-server-start.sh config/server.properties
如果需要创建kafka主题,可以输入以下命令:
bin/kafka-topics.sh --create --zookeeper s202:2181 --topic calllog --replication-factor 3 --partitions 4
注意:如果你使用的是自定义的Kafka配置文件,你需要将命令中的config/server.properties
替换为你自己的配置文件路径。
作者简介
陈睿|mikechen,10年+大厂架构经验,就职于阿里巴巴、淘宝、百度等一线互联网大厂。
关注作者「mikechen」公众号,获取更多技术干货!
后台回复【架构】,即可获取《阿里架构师进阶专题全部合集》,后台回复【面试】即可获取《史上最全阿里Java面试题总结》