docker-compose部署kafka全過程

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

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

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容器外訪問這里要寫宿主機(jī)的ip 否則會報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

啟動容器

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 表示你想要創(chuàng)建的分區(qū)數(shù)量為 1，--replication-factor 1 表示每個分區(qū)的副本因子為 1（通常在生產(chǎn)環(huán)境中，你會希望設(shè)置更高的副本因子以增加容錯性）。--if-not-exists 是一個可選參數(shù)，用于在 topic 已經(jīng)存在時防止報錯。

查看并監(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的起始位置開始讀取消息 不帶該參數(shù)默認(rèn)從最新偏移量開始監(jiān)控消費(fèi)

總結(jié)

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

您可能感興趣的文章:

相關(guān)文章

詳解docker強(qiáng)制批量刪除none的image鏡像
這篇文章主要介紹了詳解docker強(qiáng)制批量刪除none的image鏡像，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2017-06-06
Docker?cp命令詳解之如何在Docker容器和主機(jī)之間復(fù)制文件/文件夾
要從Docker容器中復(fù)制文件,可以使用docker?cp命令,下面這篇文章主要給大家介紹了關(guān)于Docker?cp命令詳解之如何在Docker容器和主機(jī)之間復(fù)制文件/文件夾的相關(guān)資料,文中通過圖文介紹的非常詳細(xì),需要的朋友可以參考下
2024-07-07
Docker中限制CPU和內(nèi)存的使用的方法
在容器化的動態(tài)世界中,Docker 已經(jīng)成為構(gòu)建、部署和管理容器化的關(guān)鍵工具應(yīng)用,設(shè)置適當(dāng)?shù)膬?nèi)存和 CPU 限制對于優(yōu)化 Docker 性能至關(guān)重要,確保每個容器在不使主機(jī)負(fù)擔(dān)過重的情況下獲得必要的資源,本文將深入探討有效設(shè)置這些限制的實(shí)用策略,需要的朋友可以參考下
2025-01-01
idea使用docker生成鏡像(打包鏡像,導(dǎo)入鏡像,導(dǎo)出鏡像)
使用docker鏡像,可以快速地部署和運(yùn)行應(yīng)用程序,而無需擔(dān)心環(huán)境差異、依賴項(xiàng)問題等,本文主要介紹了idea使用docker生成鏡像,具有一定的參考價值,感興趣的可以了解一下
2024-02-02
Docker安裝Oracle_11g的方法
這篇文章主要介紹了Docker安裝Oracle_11g的方法，本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
2021-04-04
Docker查看及修改Redis容器密碼的實(shí)用指南
在使用 Docker 部署 Redis 容器時,有時我們需要查看或修改 Redis 的密碼,本文將詳細(xì)介紹如何在 Docker 中查看和修改 Redis 容器的密碼,幫助你更好地管理和維護(hù)你的 Redis 實(shí)例,需要的朋友可以參考下
2024-07-07
Docker 搭建 Tomcat 運(yùn)行環(huán)境的方法
這篇文章主要介紹了Docker 搭建 Tomcat 運(yùn)行環(huán)境的方法,Docker與虛擬機(jī)及搭建過程，介紹的非常詳細(xì)，需要的朋友可以參考下
2016-10-10
docker的WSL2報錯解決步驟記錄
這篇文章主要介紹了在使用Docker時遇到的WSL2不支持的問題,包括錯誤代碼、解決方法和常見問題,解決方法主要包括啟用BIOS虛擬化、安裝WSL2內(nèi)核、設(shè)置默認(rèn)WSL版本等步驟,需要的朋友可以參考下
2025-04-04
docker中Dockerfile方式建立鏡像HelloWorld
這篇文章主要介紹了docker中Dockerfile方式建立鏡像HelloWorld，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2017-07-07
Docker無法登錄與推送問題解決的詳細(xì)教程
這篇文章主要介紹了如何使用阿里云容器鏡像服務(wù)來解決國內(nèi)訪問Docker?Hub速度慢的問題,并詳細(xì)描述了如何設(shè)置阿里云鏡像服務(wù)、配置Docker、操作鏡像（包括pull和push）以及測試?yán)＄R像的過程,需要的朋友可以參考下
2025-02-02