本篇內(nèi)容主要講解“Docker下kafka的功能是什么”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“Docker下kafka的功能是什么”吧!

創(chuàng)新互聯(lián)公司長期為1000+客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對不同對象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺，與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為唐縣企業(yè)提供專業(yè)的網(wǎng)站制作、做網(wǎng)站，唐縣網(wǎng)站改版等技術(shù)服務(wù)。擁有10多年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。

Kafka是一種高吞吐量的分布式發(fā)布訂閱消息系統(tǒng)，從本章開始我們先極速體驗(yàn)，再實(shí)戰(zhàn)docker下搭建kafka環(huán)境，最后開發(fā)一個(gè)java web應(yīng)用來體驗(yàn)kafka服務(wù)。

新建一個(gè)docker-compose.yml文件，內(nèi)容如下：

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所在目錄下執(zhí)行docker-compose up -d，由于需要從hub.docker.com下載鏡像，所以需要等待幾分鐘，下載結(jié)束后會自動(dòng)啟動(dòng)四個(gè)容器，如下圖：

為了更好的觀察效果，我們要打開三個(gè)終端對不同的容器做操作，在后面我們用編號來表達(dá)不同的終端，編號對應(yīng)如下：

1號 : kafka server 2號 : 消息生產(chǎn)者(producer) 3號 : 消息消費(fèi)者(consumer)

1號終端中輸入以下命令，即可看到kafka server的實(shí)時(shí)輸出信息：

docker logs -f dockerkafka_kafka_server_1

輸入命令后看到的信息如下圖，與zookeeper連接成功，啟動(dòng)成功:

2號終端中輸入以下命令，進(jìn)入消息生產(chǎn)者容器：

docker exec -it dockerkafka_message_producer_1 /bin/bash

再執(zhí)行以下命令創(chuàng)建一個(gè)主題：

$WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-topics.sh --create --zookeeper zkhost:2181 --replication-factor 1 --partitions 1 --topic test001

3號終端中輸入以下命令，進(jìn)入消息消費(fèi)者容器：

docker exec -it dockerkafka_message_consumer_1 /bin/bash

執(zhí)行以下命令可以查看當(dāng)前kafka sever上的所有主題：

$WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-topics.sh --list --zookeeper zkhost:2181

可以看到剛才在2號終端創(chuàng)建的主題，如下圖：

繼續(xù)在3號終端上執(zhí)行以下命令，即可訂閱主題為test001的消息：

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

此時(shí)回到1號終端，可以看到消息訂閱者容器的連接信息，如下圖：

現(xiàn)在主題也創(chuàng)建了，訂閱也添加了，可以測試消息的發(fā)送和接收了：

在2號終端，執(zhí)行以下命令，就可以進(jìn)入發(fā)送消息的交互模式：

$WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-console-producer.sh --broker-list kafkahost:9092 --topic test001

此時(shí)已經(jīng)進(jìn)入了交互模式，繼續(xù)輸入一個(gè)字符串，例如hello world!，再輸入回車鍵，即可發(fā)送內(nèi)容為"hello world!"的消息，如下圖：

現(xiàn)在回到3號終端，可以看到已經(jīng)接收到了最新的消息，內(nèi)容被打印出來了，如下圖：

最后我們回到1號終端，能看到消息生產(chǎn)者的連接信息，如下圖：

到此，相信大家對“Docker下kafka的功能是什么”有了更深的了解，不妨來實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！