zkServer.sh start
再启动kafka:
kafka-server-start.sh $KAFKA_HOME/config/server.properties &
全部都启动完毕之后jps查看:
启动成功!
创建一个Topic:bin/kafka-topics.sh --zookeeper spark-local:2181 --create --replication-factor 1 --partitions 1 --topic myTopic
--topic后面跟的是创建topic的name
--replication-factor后面跟的是副本数 副本数不能大于可用的docker
--partitions后面跟的是分区数
myTopic就是刚刚创建的topic
然后再创建一个Topic------myTopi
kafka-topics.sh --delete --zookeeper spark-local:2181 --topic myTopi
再查看就没有了myTopi
查看myTopic的详情:
bin/kafka-topics.sh --describe --topic myTopic --zookeeper spark-local:2181
可以看到分区数,副本数,leader等信息。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)