kafka的启动命令(kafka启动失败原因)

导语：kafka启动顺序&命令启动

1.启动顺序

2.启动命令2.1 启动zookeeper

/opt/kafka_2.11-1.0.0/bin/zookeeper-server-start.sh -daemon /opt/kafka_2.11-1.0.0/config/zookeeper.properties

-daemon （守护进程启动）

使用jps 查看是否启动

2.2 启动kafka-server

/opt/kafka_2.11-1.0.0/bin/kafka-server-start.sh -daemon /opt/kafka_2.11-1.0.0/config/server.properties

2.3 查看已有主题

/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --list --zookeeper 192.168.224.130:2181

2.4 删除已有主题

/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --delete --zookeeper 192.168.224.130:2181 --topic test

2.5 创建新主题

/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --create --zookeeper 192.168.224.130:2181 --partitions 1 --replication-factor 1 --topic test

2.6 启动生产者-发送消息

/opt/kafka_2.11-1.0.0/bin/kafka-console-producer.sh --broker-list 192.168.224.130:9092 --topic test

2.7 启动消费者-拉取消息

/opt/kafka_2.11-1.0.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.224.130:9092 --topic test --from-beginning

--from-beginning 获取所有历史消息

免责声明:本站部份内容由优秀作者和原创用户编辑投稿，本站仅提供存储服务，不拥有所有权,不承担法律责任。若涉嫌侵权/违法的，请反馈，一经查实立刻删除内容。本文内容由快快网络小思创作整理编辑！