docker学习（一）docker概述docker学习（二）docker安装部署docker学习（三）常用命令docker学习（四）使用commit制作镜像docker学习（五）使用Dockerfile制作镜像docker学习（六）卷Volumedocker学习（七）dockerdaemondocker学习（八）HTTP/HTTPS代理docker学习（九）docker调试docker学习（十）docker持久化存储docker容器操作1.docker环境信息—docker[info|version]2.容器生命周期管理—docker[create|exec|run|start|stop|re
一、前言总体思路：source-->transform-->sink,即从source获取相应的数据来源，然后进行数据转换，将数据从比较乱的格式，转换成我们需要的格式，转换处理后，然后进行sink功能，也就是将数据写入的相应的数据库DB中或者写入Hive的HDFS文件存储。思路：pom部分放到最后面。二、方案及代码实现2.1Source部分Source部分构建一个web对象用于保存数据等操作，代码如下：packagecom.lzl.flink;importjava.util.Date;/***@authorlzl*@create2024-01-1812:19*@namepojo*/public
Centos的docker部署安装超详细教程（零基础可用）以及docker常用命令详解（图文结合纯干货，适用于初学者）一.Centos7安装部署docker安装环境基础环境配置禁用防火墙和关闭selinux永久关闭开始安装此时，就已经完成了docker安装，下面需要做一些简单的配置二.docker常用命令大全（纯干货）docker最常用命令常用命令下载镜像（拉取镜像）搜索镜像启动容器查看docker进程删除容器导入和导出容器导出容器导入容器删除镜像利用docker运行一个简单的web应用一.Centos7安装部署docker安装环境系统：centos7内存：4G网络类型：NAT模式硬盘大小：8
目录一、系统级别类命令1.启动docker2.停止Docker3.重启Docker4.查看状态5.设置开机自启6.取消开机自启7.查看占据的空间二、帮助类命令1.查看Docker版本2.查看Docker概要信息3、查看Docker总体帮助文档4、查看docker具体命令帮助文档三、容器管理命令1.列出运行中的容器2.列出本地主机上的镜像3.删除容器4.搜索DockerHub中镜像5.下载Docker镜像6.创建并运行一个新的Docker容器6.1运行交互式容器6.2在后台运行容器6.3映射端口6.4设置环境变量6.5挂载卷6.6工作目录设置6.7 容器重启策略6.8 删除容器在退出时6.9重新
【Kafka】Suppressed:java.nio.file.AccessDeniedException问题的解决 目录前言一、错误发生的原因二、问题如何解决前言今天在运行kafka时，出现了如下图的报错Suppressed:java.nio.file.AccessDeniedException，怎么启动也启动不起来。那此问题怎么解决呢？一、错误发生的原因我通过链接工具链接了kafka，然后删除了一个topics之后就报了这样的错误，也就是说是删除的问题出现了错乱导致的报错。 二、问题如何解决可能是Kafka中的数据与zookeeper中数据不一致造成。需要删掉相应的文件，我这里把kafka
Kafka作为一款高性能的消息中间件系统，其消息格式对于消息的生产、传输和消费起着至关重要的作用。本篇博客将深入讨论Kafka的消息格式，包括消息的结构、序列化与反序列化，以及一些常用的消息格式选项。通过更丰富的示例代码和深入的解析，希望能够帮助大家更好地理解Kafka消息的内部机制。1.Kafka消息结构Kafka的消息结构由消息头、消息键、消息值和时间戳等组成。下面是一个典型的Kafka消息结构：----------------------------------------------------------------------------------------------|Mes
目录Kafka概述为什么需要消息队列（MQ）使用消息队列的好处消息队列的两种模式Kafka定义Kafka简介Kafka的特性Kafka系统架构在zookeeper集群的基础上部署kafka集群部署zookeeper集群部署kafka集群下载安装包 安装KafkaKafka命令行操作Kafka架构深入Kafka工作流程及文件存储机制数据可靠性保证数据一致性问题ack应答机制部署Filebeat+Kafka+ELK集群部署Zookeeper+Kafka集群部署Filebeat,并添加开启httpd服务部署ELK，在Logstash组件所在节点上新建一个Logstash配置文件Kafka概述为什么需
目录一、git的特点二、git本地仓库1初始化空的git版本仓库（.git/目录）2版本创建3查看版本记录4查看操作记录5版本回退6工作区与暂存区与版本库7撤销修改8对比文件不同9删除文件三、git分支1分支基础命令2解决分支冲突3git分支管理策略4修复bug的临时分支四、github远程仓库1添加ssh账户2克隆项目3推送代码4跟踪远程5拉取代码一、git的特点版本控制：可以解决多人同时开发的代码问题，也可以解决找回历史代码的问题。分布式：git是分布式版本控制系统，同一个git仓库，可以分布到不同的机器上。首先找一台电脑充当服务器的角色，每天24小时开机，其他每个人都从这个"服务器"仓库
目录1-单播模式，只有一个消费者组2-广播模式，多个消费者组3-Java实践kafka是由Apache软件基金会开发的一个开源流处理平台。kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。kafka中partition类似数据库中的分表数据，可以起到水平扩展数据的目的，比如有a,b,c,d,e,f6个数据，某个topic有两个partition，一般情况下partition-0存储a,c,e3个数据，partition-1存储b,d，f另外3个数据。1-单播模式，只有一个消费者组topic只有1个partition,该组内有多个消费者时，此时同一个pa
这次主要介绍生产工作中使用Starrocks时的常用命令4.1连接StarRocks4.1.1Linux命令行连接[root@hadoop1011fe]#yuminstallmysql-y[root@hadoop1011fe]#mysql-hhadoop101-uroot-P9030-p4.1.2Windows客户端DBeaver连接4.2常用命令4.2.1查看状态1.查看fe状态showPROC'/frontends';showfrontends;showfrontends\G;2.查看be状态showbackends;showbackends\G;3.切换到数据库查看表大小showdata
