使用docker搭建kafka集群、可视化操作台

单机搭建

一、安装kafka

1.安装前要先了解:由于kafka依赖zookeeper环境,所以要先安装zookeeper、再安装kafka
2.安装zookeeper

sudo docker pull wurstmeister/zookeeper

在这里插入图片描述
3.安装kafka

sudo docker pull wurstmeister/kafka

在这里插入图片描述
4.分别启动zookeeper和kafka

# 1、创建并启动zookeeper
sudo docker run -d --name zookeeper -p 2181 -t wurstmeister/zookeeper# 2、创建并启动kafka
sudo docker run -d --name kafka -p 9092:9092 
-e KAFKA_BROKER_ID=1 
-e KAFKA_ZOOKEEPER_CONNECT=192.168.158.130:2181/kafka 
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.158.130:9092 
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
-v /etc/localtime:/etc/localtime    wurstmeister/kafka# 3、说明:
KAFKA_BROKER_ID=1 kafka在集群中的唯一标识
KAFKA_ZOOKEEPER_CONNECT=192.168.158.130:2181 监听zookeeper的地址
KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.158.130:9092 kafka服务器的地址
KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 指定端口

在这里插入图片描述
5.进入kafka容器,使用kafka创建消息生产者,和消息消费者

# 进入容器
docker exec -it 容器ID bash# 运行kafka生产者发送消息
/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic hellokafka# 重新开一个窗口
# 运行kafka消费者接受消息
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic hellokafka

二、安装kafka-map可视化

1、 拉取kafka-map镜像
docker pull dushixiang/kafka-map:latest

2、启动kafka-map容器

docker run -d --name kafka-map -p 9001:8080-v /opt/kafka-map/data:/usr/local/kafka-map/data-e DEFAULT_USERNAME=admin-e DEFAULT_PASSWORD=admindushixiang/kafka-map:latest

3、访问:http://192.168.56.103:9001
在这里插入图片描述
点击右上角+号完成kafka的接入:
在这里插入图片描述

集群搭建

本次基于docker搭建kafka集群,zookeeper使用单实例

1、准备2台虚拟机,ip分别是:192.168.56.103,192.168.56.104

2、104 上操作

a、拉取zookeeper镜像

docker pull wurstmeister/zookeeper 

b、启动zookeeper容器

docker run -d  --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime                         wurstmeister/zookeeper

c、拉取kafka镜像

docker pull wurstmeister/kafka

e、拉取kafka-map镜像

docker pull dushixiang/kafka-map:latest

f、启动kafka-map容器

    docker run -d --name kafka-map-p 9001:8080-v /opt/kafka-map/data:/usr/local/kafka-map/data-e DEFAULT_USERNAME=admin-e DEFAULT_PASSWORD=admindushixiang/kafka-map:latest

3、103上操作

a、拉取kafka镜像

docker pull wurstmeister/kafka

b、启动kafka容器

docker run -d  --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=2 -e                         KAFKA_ZOOKEEPER_CONNECT=192.168.56.103:2181/kafka -e                         KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.56.103:9092 -e                         KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime                         wurstmeister/kafka

注意:103和104启动kafka的区别就是指定不同的KAFKA_BROKER_ID,如果是以配置文件启动的,在配置文件中修改即可

4 登录到kafka-map上创建对应的kafka集群信息,实现界面化操作

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

CAN网络管理(网络节点)

什么是CAN的网络节点 网络节点是指连接到CAN总线上的设备或模块,每个网络节点都具有唯一的标识符,称为节点ID,用于在CAN总线上进行通信和识别。 如何判断CAN的网络节点是多少 可以根据DBC来定义查看, 以ADCU为例,域控作为主节点,一般外部的像雷达,camera的数据都是向…

gpt-4击败claude3,成为最强AI大模型

最近,gpt-4再次击败claude3,重新夺回全球最强AI大模型宝座! 在最近的AI基准测试中,OpenAI刚刚发布的GPT-4-Turbo-2024-04-09版本,实现了对Claude3 Opus的大幅领先,重新夺回了全球AI霸主的地位:…

密码学 | 椭圆曲线数字签名方法 ECDSA(下)

目录 10 ECDSA 算法 11 创建签名 12 验证签名 13 ECDSA 的安全性 14 随机 k 值的重要性 15 结语 ⚠️ 原文:Understanding How ECDSA Protects Your Data. ⚠️ 写在前面:本文属于搬运博客,自己留着学习。同时,经过几…

恶意软件逆向工程:Ghidra 入门 -第一部分

在逆向工程领域有许多优秀的工具可以使用(比如IDA Pro和OllyDbg),但现在我们有一个新的选择-Ghidra。Ghidra是由美国国家安全局(美国主要的间谍机构,负责开发Stuxnet恶意软件和EternalBlue的机构)开发的&am…

倍增法学习

这里i为开始下标,j是2的次幂

动态IP代理API是什么?怎么用?

“动态”意味着每次连接或每隔一段时间,用户的IP地址都会发生改变。由于IP地址的不断变化,用户可以避免因频繁访问同一网站而导致的IP被封锁的问题。API叫做应用程序接口,是一种让软件之间相互通信的接口。API允许用户通过编程方式来调用动态…

如何学习VBA_3.2.20:DTP与Datepicker实现日期的输入

我给VBA的定义:VBA是个人小型自动化处理的有效工具。利用好了,可以大大提高自己的劳动效率,而且可以提高数据处理的准确度。我推出的VBA系列教程共九套和一部VBA汉英手册,现在已经全部完成,希望大家利用、学习。 如果…

保护你的数据隐私!新技术将实现绝对安全的「量子云计算」

听说过物质-光子混合实现可验证的盲量子计算(blind quantum computing)吗? "盲量子计算"是一种使用户能够远程利用量子计算服务商的量子设备执行计算的模式。这一技术可能使数百万个人和企业安全地接入下一代量子计算机&#xff0c…

Python编程之旅:深入探索强大的容器——列表

在Python编程的世界中,容器(Containers)是一种用于存储多个项目的数据结构。其中,列表(List)是最常用且功能强大的容器之一。无论是初学者还是资深开发者,掌握列表的使用方法和技巧都是提升Pyth…

Linux/Cronos

Cronos 天热了,什么也不想干,拿以前的来凑个数 Enumeration Nmap 扫描发现对外开放了22,53,80端口,使用nmap详细扫描这几个端口 ┌──(kali㉿kali)-[~/vegetable/HTB/cronos] └─$ nmap -sC -sV -p 22,53,80 -oA…

【Git教程】(十二)工作流之项目设置 — 何时使用工作流,工作流的结构,项目设置概述、执行过程及其实现 ~

Git教程 工作流之项目设置 1️⃣ 何时使用工作流2️⃣ 工作流的结构3️⃣ 概述4️⃣ 使用要求5️⃣ 执行过程及其实现5.1 基于项目目录创建一个新的版本库5.2 以文件访问的方式共享版本库5.3 用 Git daemon 来共享版本库5.4 用 HTTP 协议来共享版本库5.5 用 SSH 协议来共享版…

AI 业务应用经验:以零一万物的万知 AI 创作为例

作者:明明如月学长, CSDN 博客专家,大厂高级 Java 工程师,《性能优化方法论》作者、《解锁大厂思维:剖析《阿里巴巴Java开发手册》》、《再学经典:《Effective Java》独家解析》专栏作者。 热门文章推荐&am…