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
替换为你自己的配置文件路径。