kafka0.8

作者: 我心悠然 | 来源:发表于2020-08-06 11:38 被阅读0次

    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命令: kafka-topics --zookeeper 127.0.0.1:2181 --list

    查看topic详情命令: kafka-topics --zookeeper 127.0.0.1:2181 --topic TT-TOPIC --describe

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

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

    相关文章

      网友评论

        本文标题:kafka0.8

        本文链接:https://www.haomeiwen.com/subject/qsiyrktx.html