docker 单节点arm架构服务器安装zookeeper、kafka并测试通信

kafka、zookeeper常用镜像介绍

kafka和zookeeper常见的镜像有以下三个:wurstmeister/zookeeper、kafka、confluentinc/cp-zookeeper、cp-kafka 和 bitnami/zookeeper、kafka。

wurstmeister/xxx: 由wurstmeister团队维护,提供的镜像适用于开发和测试环境,具有便捷部署、版本多样、可自定义配置等特点。通过 Docker 一键启动 Kafka 集群,无需安装额外软件,大大简化了运维工作,对于想要快速搭建 Kafka 环境进行开发和测试的用户非常方便。但是,在生产环境中可能缺乏某些高级功能和优化。

confluentinc/xxx: 这个镜像由Confluent公司维护,是Kafka的官方镜像之一。适合构建复杂的 Kafka 集群和生产环境,为企业级用户提供了更全面、功能更强大的 Kafka 解决方案,包括对 Kafka 的企业级支持和服务、完全托管的 Confluent Cloud 服务等,能够满足企业对于数据处理的高要求和高可靠性需求。

bitnami/kafka: Bitnami 是一个提供各种流行应用的 Docker 镜像和软件包的开源项目,旨在为用户提供打包好的软件堆栈,使得在各种操作系统上部署各种应用程序变得轻松且高效。对于想要快速、简单地部署 Kafka 的用户来说是一个不错的选择,适用于一些对 Kafka 功能需求不是特别复杂,但又希望能够快速搭建和使用的场景,例如小型项目或个人实验等。

总的来说,Wurstmeister 适合快速搭建测试环境;Confluent Inc 提供企业级的 Kafka 解决方案;Bitnami 则提供简单易用的 Kafka 部署以及便捷的应用管理工具,用户可以根据自己的需求和场景选择适合的产品或服务。

docker 单节点arm架构服务器安装zookeeper

首先我们安装zookeeper,由于wurstmeister/zookeeper,在arm架构自动拉取不到arm的镜像,所以我们选择bitnami/zookeeper。

docker pull bitnami/zookeeper

以防镜像架构拉错,可以通过以下命令检查镜像是不是arm架构的

docker inspect bitnami/zookeeper

在这里插入图片描述
如下图所示是arm架构。
在这里插入图片描述
接着执行下列命令运行容器

docker run -d --name zookeeper -p 2181:2181   -e ALLOW_ANONYMOUS_LOGIN=yes   bitnami/zookeeper:latest

如图所示表示正常运行
在这里插入图片描述

docker 单节点arm架构服务器安装kafka并测试通信

拉取kafka镜像

docker pull bitnami/kafka
docker inspect bitnami/kafka:latest

启动kafka

docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=ip_address:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://ip_address:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 bitnami/kafka

测试搭建的kafka是否可以正常进行发布、消费消息

服务器开启两个窗口同时进入到容器中

docker exec -it 容器id /bin/bash

每个镜像存放kafka脚本启动目录的地方有差异,我使用的bitnami/kafka镜像脚本启动目录在如下地址:

cd /opt/bitnami/kafka/bin/

在这里插入图片描述
启动发布消息脚本,并创建test的topic,生产者发送消息

./kafka-console-producer.sh --broker-list localhost:9092 --topic test

在这里插入图片描述

消费者订阅主题

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

添加–from-beginning命令是让消费者从头开始消费topic里的消息,若不添加消费者只会从当前发送的消息开始消费。
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/901102.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Mac apache配置cgi环境-修改httpd.conf文件、启动apache

Mac自带Apache,配置CGI,分以下几步: 找到httpd.conf。打开终端,编辑以下几处,去掉#或补充内容。在这个路径下写一个测试文件.py格式的,/Library/WebServer/CGI-Executables,注意第一行的python…

矩阵概念 和 性质

目录 一、矩阵因式分解 二、矩阵在图形学的运用 一、矩阵因式分解 1、先将矩阵化为上三角阵,得到U 2、每个主元列以下元素 主元 得到下三角阵 二、矩阵在图形学的运用 二维移动: 子空间H: 零向量属于H 对H中任意向量u、v,uv…

2024-10-25 算法学习及论文辅导(每日更新,随时联系)

看看学习小群的学习氛围👇🏻 很多同学自己学习遇到问题没人解决,最终消耗了时间,精力同时大大消耗了自己对学习的信心😧 🥳来看看跟班学习,大家遇到问题的时候是怎么解决的: 首先…

idea安装visualVm插件

idea 安装visualVM插件用于分析java程序, 1.在插件市场安装visualvm launcher 2.安装成功后,重启idea,此时启动按钮旁边有这两个按钮 3.需要在这里配置插件的visualvm位置 4.配置完后,点击启动

ArcGIS计算落入面图层中的线的长度或面的面积

本文介绍在ArcMap软件中,计算落入某个指定矢量面图层中的另一个线图层的长度、面图层的面积等指标的方法。 如下图所示,现在有2个矢量要素集,其中一个为面要素,表示某些区域;另一个为线要素,表示道路路网。…

Linux相关概念和易错知识点(16)(Shell原理、进程属性和环境变量表的联系)

Shell原理及其模拟实现 在认识进程exec系列函数、命令行参数列表、环境变量之后,我们可以尝试理解一下Shell的原理,将各方知识串联起来,让Shell跑起来才能真正理解这些概念。我会以模拟Shell执行的原理模拟一个Shell。途中配上相关讲解。 1…

InnoDB 存储引擎<一>InnoDB简介与MySQL存储架构及相关数据结构

目录 回顾MySQL架构 InnoDB简介 ​MySQL存储结构 回顾MySQL架构 对MySQL架构图的总结: MySQL服务器是以网络服务的方式对外提供数据库服务的,我们使用的应用程序以及客户端统称为外部程序。 外部程序通过发送网络请求的方式来连接MySQL服务器,这时首先每…

Leetcode239. 滑动窗口最大值

问题描述: 给你一个整数数组 nums,有一个大小为 k 的滑动窗口从数组的最左侧移动到数组的最右侧。你只可以看到在滑动窗口内的 k 个数字。滑动窗口每次只向右移动一位。 返回 滑动窗口中的最大值 。 示例 1: 输入:nums [1,3,…

Python爬虫教程:从入门到精通

Python爬虫教程:从入门到精通 前言 在信息爆炸的时代,数据是最宝贵的资源之一。Python作为一种简洁而强大的编程语言,因其丰富的库和框架,成为了数据爬取的首选工具。本文将带您深入了解Python爬虫的基本概念、实用技巧以及应用…

文件下载漏洞

文件安全 文件下载 常见敏感信息路径 Windows C:\boot.ini //查看系统版本 C:\Windows\System32\inetsrv\MetaBase.xml //IIS配置文件 C:\Windows\repair\sam //存储系统初次安装的密码 C:\Program Files\mysql\my.ini //Mysql配置 C:\Program Files\mysql\data\mysql\user.…

Python小游戏13——植物大战僵尸

代码 import random import time # 植物类 class Plant: def __init__(self, name, health): self.name name self.health health def is_alive(self): return self.health > 0 # 僵尸类 class Zombie: def __init__(self, name, health): self.name name self.health h…

Tornado简单使用

Tornado简单使用 1 介绍 Tornado 是一个基于Python的Web服务框架和 异步网络库,它最初由 FriendFeed 开发,后来被 Facebook 收购并开源,通过利用非阻塞网络 I/O, Tornado 可以承载成千上万的活动连接,完美的实现了 长连接、WebS…

关于 Linux 内核“合规要求”与俄罗斯制裁的一些澄清

原文:Michael Larabel - 2024.10.24 当 一些俄罗斯的 Linux 开发者被从内核的 MAINTAINERS 文件中移除 时,原因被描述为“合规要求”,但并未明确这些要求具体涉及什么内容。随后,Linus Torvalds 对此发表了评论,明确指…

SIP 业务举例之 三方通话:邀请第三方加入的信令流程

目录 1. 3-Way Conference - Third Party Is Added 简介 2. RFC5359 的 3-Way Conference - Third Party Is Added 信令流程 3. 3-Way Conference - Third Party Is Added 总结 博主wx:yuanlai45_csdn 博主qq:2777137742 想要 深入学习 5GC IMS 等通信知识(加入 51学通信)…

[bug] vllm 0.6.1 RuntimeError: operator torchvision::nms does not exist

[bug] vllm 0.6.1 RuntimeError: operator torchvision::nms does not exist 环境 python 3.10 torch 2.4.0cu118 torchvision 0.19.0cu118 vllm 0.6.1.post2cu118问题详情 if torch._C._d…

Spring Boot框架中小企业设备监控系统开发

3系统分析 3.1可行性分析 通过对本中小企业设备管理系统实行的目的初步调查和分析,提出可行性方案并对其一一进行论证。我们在这里主要从技术可行性、经济可行性、操作可行性等方面进行分析。 3.1.1技术可行性 本中小企业设备管理系统采用Spring Boot框架&#xff0…

ubuntu20.04上使用 Verdaccio 搭建 npm 私有仓库

安装nvm 首先安装必要的工具: apt update apt install curl下载并执行nvm安装脚本: curl -o- https://raw.githubusercontent.com/nvm-sh/nvm/v0.39.7/install.sh | bash添加环境变量(如果安装脚本没有自动添加)。编辑 ~/.bash…

java项目之基于web的智慧社区设计与实现(springboot)

风定落花生,歌声逐流水,大家好我是风歌,混迹在java圈的辛苦码农。今天要和大家聊的是一款基于springboot的基于web的智慧社区设计与实现。项目源码以及部署相关请联系风歌,文末附上联系信息 。 项目简介: 基于web的智…

使用TimeShift备份和恢复Ubuntu Linux

您是否曾经想过如何备份和恢复您的Ubuntu或Debian系统?TimeShift是一个强大的备份和还原工具。TimeShift允许您创建系统快照,提供了一种在出现意外问题或系统故障时恢复到先前状态的简便方式。您可以使用RSYNC或BTRFS创建快照。 有了这个介绍&#xff0…

萤石设备视频接入平台EasyCVR私有化视频平台变电站如何实现远程集中监控?

一、方案背景 随着城市经济的发展和电力系统的改造,变电站的数量和规模逐渐增加,对变电站的安全管理和监控需求也越来越高。视频监控系统作为重要的安全管理手段,在变电站中起到了关键的作用。 目前青犀视频研发的萤石设备视频接入平台EasyC…