kafka集群创建topic命令

./kafka-topics.sh –create –replication-factor <副本数> –partitions <分区数> –zookeeper zk1:port1,zk2:port2,zk3:port3 –topic <Topic 名称> retention.ms  <保留时间>

zk1,zk2,zk3 是zookeeper的主机名, port1,port2和port3是zookeeper的端口号

发表评论

电子邮件地址不会被公开。 必填项已用*标注