0
点赞
收藏
分享

微信扫一扫

kafka0.8

蓝哆啦呀 2021-09-30 阅读 42

1、Kafka分为:生产者(producer),消费者(consumer)

2、生产者提交消息,给Kafka集群,然后Kafka集群调用消费者(kafka对消息进行归纳,即topic,也就是说producer发布topic,consumer订阅topic)

kafka通过brew install kafka命令安装;kafka安装路径:/usr/local/Cellar/kafka/

配置文件路径:

/usr/local/etc/kafka/server.properties

/usr/local/etc/kafka/zookeeper.properties

kafka默认端口:9092,zookeeper默认端口:2181

启动命令:(进入bin目录后执行以下命令,启动zookeeper和kafka)

1、./kafka-server-start /usr/local/etc/kafka/server.properties &

2、./zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &

查看topic命令: sh kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

查看topic详情命令: sh kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic xxx --describe

创建topic命令: sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic xxx

删除topic命令: sh kafka-topics.sh --delete --zookeeper localhost:2181 --topic xxx

查看消费列表信息: sh kafka-console-consumer.sh --bootstrap-server 192.168.100.35:9092 --topic TT-TOPIC --from-beginning

往消费者里面直接插入数据:sh kafka-console-producer.sh --broker-list localhost:9092 --topic xxx

kafkaTool工具:https://www.kafkatool.com/download.html

代码路径:https://github.com/lunacai/canace-kafka08-demo

举报

相关推荐

0 条评论