快捷導(dǎo)航

docker-compose部署kafka全過(guò)程

更新時(shí)間：2024年12月19日 09:23:55 作者：lcz-2000

文章介紹了如何使用docker-compose.yaml文件啟動(dòng)容器,并查看和創(chuàng)建Kafka topic,以及監(jiān)控topic下的數(shù)據(jù),作者分享了個(gè)人經(jīng)驗(yàn),希望對(duì)大家有所幫助

docker-compose部署kafka

docker-compose.yaml文件

version: '3'
services:
  zookeeper:
    image: bitnami/zookeeper:latest
    container_name: zookeeper
    environment:
      - ALLOW_ANONYMOUS_LOGIN=yes
    network_mode: host
  kafka:
    image: bitnami/kafka:latest
    container_name: kafka
    environment:
      - KAFKA_BROKER_ID=1
      - KAFKA_CFG_LISTENERS=PLAINTEXT://主機(jī)IP地址:9092
      - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://主機(jī)IP地址:9092 #如果是docker容器外訪問(wèn)這里要寫宿主機(jī)的ip 否則會(huì)報(bào)Error connecting to node kafka:9092 (id: 1 rack: null) java.net.UnknownHostException: 不知道這樣的主機(jī)。
      - KAFKA_CFG_ZOOKEEPER_CONNECT=主機(jī)IP地址:2181
      - ALLOW_PLAINTEXT_LISTENER=yes
    depends_on:
      - zookeeper
    network_mode: host

啟動(dòng)容器

docker-compose up -d

查看已創(chuàng)建的topic

docker exec -it kafka kafka-topics.sh --list --bootstrap-server 主機(jī)IP地址:9092

創(chuàng)建topic

//方式一
docker exec -it kafka kafka-console-producer.sh --bootstrap-server 主機(jī)IP地址:9092 --topic test
//方式二
docker exec kafka kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1 --if-not-exists --bootstrap-server 主機(jī)IP地址:9092
//Created topic test.
//--partitions 1 表示你想要?jiǎng)?chuàng)建的分區(qū)數(shù)量為 1，--replication-factor 1 表示每個(gè)分區(qū)的副本因子為 1（通常在生產(chǎn)環(huán)境中，你會(huì)希望設(shè)置更高的副本因子以增加容錯(cuò)性）。--if-not-exists 是一個(gè)可選參數(shù)，用于在 topic 已經(jīng)存在時(shí)防止報(bào)錯(cuò)。

查看并監(jiān)控topic下數(shù)據(jù)

docker exec -it kafka kafka-console-consumer.sh --bootstrap-server 主機(jī)IP地址:9092 --topic test --from-beginning
//--from-beginning 參數(shù)表示從topic的起始位置開(kāi)始讀取消息 不帶該參數(shù)默認(rèn)從最新偏移量開(kāi)始監(jiān)控消費(fèi)

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

docker容器自動(dòng)退出重啟報(bào)錯(cuò)問(wèn)題及解決
這篇文章主要介紹了docker容器自動(dòng)退出重啟報(bào)錯(cuò)問(wèn)題及解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
2023-07-07
Docker中Redis數(shù)據(jù)遷移到本地的實(shí)現(xiàn)
Redis數(shù)據(jù)庫(kù)之間的遷移是指將數(shù)據(jù)從一個(gè)Redis實(shí)例復(fù)制到另一個(gè)Redis實(shí)例的過(guò)程,本文主要介紹了Docker中Redis數(shù)據(jù)遷移到本地的實(shí)現(xiàn),具有一定的參考價(jià)值,感興趣的可以了解一下
2025-04-04
docker搭建lnmp環(huán)境的實(shí)現(xiàn)步驟
DNMP(Docker + Nginx + MySQL + PHP7/5 + Redis)是一款全功能的LNMP一鍵安裝程序,本文就來(lái)介紹一下docker搭建lnmp環(huán)境的實(shí)現(xiàn)步驟,具有一定的參考價(jià)值,感興趣的可以了解一下
2024-07-07
docker部署mysql及制作鏡像壓縮包實(shí)踐
這篇文章主要介紹了docker部署mysql及制作鏡像壓縮包實(shí)踐,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
2026-01-01
Docker中"exec format error"錯(cuò)誤架構(gòu)不匹配的原因分析和解
本文詳細(xì)介紹了Docker中“execformaterror”錯(cuò)誤的成因,并提供了兩種解決方案：使用匹配架構(gòu)的鏡像和啟用QEMU模擬器,推薦用戶使用匹配架構(gòu)的鏡像以解決架構(gòu)不匹配的問(wèn)題,感興趣的朋友跟隨小編一起看看吧
2026-01-01
docker時(shí)區(qū)問(wèn)題和遷移數(shù)據(jù)問(wèn)題
這篇文章主要介紹了docker時(shí)區(qū)問(wèn)題和遷移數(shù)據(jù)問(wèn)題，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
2020-12-12
Docker報(bào)錯(cuò)denied:requested access to the r
這篇文章主要為大家介紹了Docker報(bào)錯(cuò)denied:requested access to the resource is denied解決方法詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
2023-06-06
Windows Docker 部署 SolrCloud的方法步驟
本文主要介紹了Windows Docker 部署 SolrCloud的方法步驟,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
2024-10-10
docker通過(guò)sbom獲取組件版本和漏洞編號(hào)的方法
本文主要介紹了docker通過(guò)sbom獲取組件版本和漏洞編號(hào)的方法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
2025-05-05
docker鏡像倉(cāng)庫(kù)常用命令分享
這篇文章主要介紹了docker鏡像倉(cāng)庫(kù)常用命令,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
2025-06-06