最近更新时间:2022-07-18 19:16:23
1.如何启动kafka服务?
./kafka-server-start.sh
../config/server.properties
2.如何查看有哪些主题?
./kafka-topics.sh --list --zookeeper zk服务IP:2181
3.如何创建topic?
./kafka-topics.sh --create --zookeeper zk服务IP:2181 --replication-factor 1 --partitions 1 --topic WordCount
4.如何删除topic?
./kafka-topics.sh --zookeeper zk服务IP:2181 --delete --topic WordCount
注:不能真正删除topic只是把这个topic标记为删除(marked for deletion),要彻底把topic删除必须把kafka中与当前topic相关的数据目录和zookeeper中与当前topic相关的路径一并删除。
5.如何查看topic的详细信息?
./kafka-topics.sh -zookeeper zk服务IP:2181 -describe -topic WordCount
6.kafka生产者客户端命令是什么?
./kafka-console-producer.sh --broker-list kafka服务IP:6667 --topic WordCount
7.kafka消费者客户端命令是什么?
./kafka-console-consumer.sh --bootstrap-server localhost:6667 --from-beginning --topic WordCount
8.如何公网访问Kafka?
(1)将kafka集群每个broker节点绑定公网eip。
(2)在客户端机器目录/etc/hosts下添加所有broker节点公网eip和对应域名映射。
纯净模式