<small id='fF8wybt'></small> <noframes id='oaP1UF74T'>

  • <tfoot id='8krj6U7'></tfoot>

      <legend id='n3MTcQ96LR'><style id='jirn3'><dir id='2Uhq'><q id='fTF1d3cB'></q></dir></style></legend>
      <i id='vL0Ebnq5c'><tr id='ONsuD'><dt id='Sh8VDAQ'><q id='j8R5C2'><span id='LFMoU'><b id='ZLQ8Cmv1i'><form id='pACTXO'><ins id='e56qXQN8'></ins><ul id='zWvlws'></ul><sub id='rHsBlJ7Gm'></sub></form><legend id='ZeCrS'></legend><bdo id='jSUc'><pre id='gaUw6'><center id='6NHOnI'></center></pre></bdo></b><th id='DZblutKXsi'></th></span></q></dt></tr></i><div id='Zj69khOdy'><tfoot id='cqMW'></tfoot><dl id='K0tsdraXv'><fieldset id='hsInPF'></fieldset></dl></div>

          <bdo id='D6Xigb'></bdo><ul id='OLXilgr3E'></ul>

          1. <li id='6KbVIxYfT'></li>
            登陆

            章鱼彩票app下载安装-Docker下kafka学习三部曲之一:极速体会kafka

            admin 2019-11-05 238人围观 ,发现0个评论

            Kafka是一种高吞吐量的分布式发布订阅音讯体系,从本章开端咱们章鱼彩票app下载安装-Docker下kafka学习三部曲之一:极速体会kafka先极速体会,再实战docker下建立kafka环境,最终开发一个java web使用来体会kafka服务。

            咱们一重用最快的速度体会kafka的音讯发布订阅功用:

            新建一个docker-compose.yml文件,内容如下:

            version压倒败家夫: '2'

            services:

            zk_server:

            image: daocloud.io/library/zookeeper:3.3.6

            restart: always

            kafka_server:

            image: bolingcavalry/kafka:0.0.1

            links:

            - zk_server:zkhost

            command: /bin/sh -c '/usr/local/work/start_server.sh'

            restart: always

            message_producer:

            image: bolingcavalry/kafka:0.0.1

            links:

            - zk_server:zkhost

            - kafka_server:kafkahost

            restart: always

            message_consumer:

            image: bolingcavalry/kafka:0.0.1

            links:

            - zk_server:zkhost

            restart: always

            翻开终端,在docker-compose.yml地点目录下履行,因为需求从hub.docker.com下载镜像,所以需求等候几分钟,下载完毕后会主动发动四个容器,如下图:

            为了更好的调查作用,咱们要翻开三个终端对不同的容器做操作,在后面咱们用编号来表达不同的终端,编号对应如下:

            1号 : kafka server

            2号 : 音讯生产者(producer)

            3号 : 音讯顾客(consumer)

            1号终端中输入以下指令,即可看到kafka server的实时输出信息:

            docker logs -f dockerkafka_kafka_server_1

            输入指令后看到的章鱼彩票app下载安装-Docker下kafka学习三部曲之一:极速体会kafka信息如下图,与zookeeper衔接成功,发动成功:

            2号终端中输章鱼彩票app下载安装-Docker下kafka学习三部曲之一:极速体会kafka入以下指令,进入音讯生产者容器:

            docker exec -it dockerkafka_message_producer_1 /bin/bash

            再履行以下指令创立一个主题:

            $WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-topics.sh --create --zookeepe章鱼彩票app下载安装-Docker下kafka学习三部曲之一:极速体会kafkar zkhost:2181 --replication-factor 1 --partitions 1 --topic test001

            3号终端中输入以下指令,进入音讯顾客容器:

            docker exec -it dockerkafka_message_consumer_1 /bin/bash

            履行以下指令能够检查当时kafka sever上的一切主题:

            $WORK_PATH/$KAFKA_PACKAGE_NAME/bin章鱼彩票app下载安装-Docker下kafka学习三部曲之一:极速体会kafka/kafka-topics.sh --list --zookeeper zkhost:2181

            能够看到刚才在2号终端创立的主题,如下图:

            持续在3号终端上履行以下指令,即可订阅主题为test001的音讯:

            $WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-console-consumer.sh --zookeeper zkhost:2181 --topic test001 --from-beginning

            此刻回到1号终端,能够看到音讯订阅者容器的衔接信息,如下图:

            现在主题也创立了,订阅也添加了,能够测验音讯的发送和接纳了:

            在2号终端,履行以下指令,就能够进入发送音讯的交互形式:

            $WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-console-producer.sh --broker-list kafkahost:9092 章鱼彩票app下载安装-Docker下kafka学习三部曲之一:极速体会kafka--topic test001

            此刻现已进入了交互形式,持续输入一个字符串,例如,再输入回车键,即可发送内容为"hello world!"的音讯,如下图:

            现在回到3号终端,能够看到现已接纳到了最新的音讯,内容被打印出来了,如下图:

            最终咱们回到1号终端,能看到音讯生产者的衔接信息,如下图:

            至此,咱们快速体会了kafka的音讯发布订阅功用,下一章咱们再细说docker下kafka环境的建立进程。

            欢迎重视我的大众号:程序员欣宸

            请关注微信公众号
            微信二维码
            不容错过
            Powered By Z-BlogPHP