数据可靠性保证： 为保证producer发送的数据，能可靠的发送到指定的topic，topic的每个partition收到producer发送的数据后，....
在最近的几年时间里，数字化转型一直是行业的流行语，因为多数企业试图了解这个词的真正含义以及如何实现它。研究公司Gartne....
1. 说明 最近接到一个需求，需要将Hive数据导出到ES。根据调研情况，可以在Hive上创建外部表，通过写SQL的形式将数据导出....
虚拟私有云（Virtual Private Cloud-VPC）：是一个公共云计算资源的动态配置池，需要使用加密协议、隧道协议和其他安全程序....
1. 首先需要执行 go mod init 2. 执行go mod tidy 3. 运行bee run , 没有beego环境或者rabbitmq就百度或者看我之前的笔记安....
windows安装Hadoop 下载 下载安装hadoopd,下载相应的版本，解压到电脑的相应目录下载网址：https://gitee.com/fulsun/win....
HDFS客户端及API操作： 一、准备条件： 1. 配置环境变量 HADOOP_HOME (路径要求非中文) 2. ....
1、zookeeper自启动 参考这篇文章 https://blog.csdn.net/crystalcs2010/article/details/89918420 ** 2、kafka自启动 参考....
当我们在虚拟机上的Hadoop启动正常，但进不去Hadoop102：9870解决办法！ 例子如下： 但是网页进不去： 第一：首先看自己....
文章目录 1、通过create命令到组装创建topic需要的数据流程(scala部分)2、创建一个客户端，此客户端通过队列多线程异步发送....
02.什么是RabbitMQ 1.1MQ（Message Queue）消息队列 消息队列中间件，是分布式系统中的重要组件 主要解决，异步处理，应用....
新冠疫情肆虐的2年多时间，影响了我们生活的方方面面。居家办公、商场冷清似乎已经成了常态。在新冠疫情的打击下，企业的生....
为什么要使用MQ 消息队列（英语：Message queue）是一种进程间通信或同一进程的不同线程间的通信方式. 我们公司本身的业务体....
简述 使用pivot函数进行透视，透视过程中可以提供第二个参数来明确指定使用哪些数据项 注意：pivot只能跟在groupby之后 示例....
基本命令 bin/kafka-topics.sh --bootstrap-server 192.168.6.101:9092 --list # 创建名为test的主题 bin/kafka-topics.sh....
《基于Apache Flink的流处理》 1. 状态化流处理概述1.1 传统数据处理架构1.1.1 事务型处理1.1.2 分析型处理 1.2 状态化流....
7.1 Beats简介 Beats 平台是 Elastic.co 从 packetbeat 发展出来的数据收集器系统 beat 收集器可以直接写入 Elasticsearch....
1.基于jdk1.8创建一个maven项目 2.增加scala-sdk Project Structure - Platform Settings - Global Libraries 因为在学习中....
1、安装python3（存在则略过） https://blog.csdn.net/Beyond_F4/article/details/79724850# 虚拟环境https://blog.csdn.net....
package com.demo.common;import org.springframework.amqp.core.Binding;import org.springframework.amqp.core.BindingBuilder
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
