Docker 安装 Kafka

docker在3.0以前依赖于zookeeper,在安装kafka之前需要先安装zookeeper集群。关于 zookeeper 集群的安装本文不做介绍,大家可以自行百度。

dbeaver默认驱动安装位置

dbeaver默认驱动安装位置

hadoop本地化windows部署

· hadoop on windows· hive on windows· spark on windows(提交方式是spark on yarn)

谷粒商城笔记+踩坑(9)——上架商品spu到ES索引库

ES回顾、【查询模块】保存ES文档、【库存模块】库存量查询、【商品模块】上架单个spu

hbase 设置超时参数

hbase设计的目标是成为一个高可用集群,能够在失败的时候快速响应,当出现网络抖动等偶发情况时,能快速重试,让用户可以快速拿到结果。而不是一直卡着,使得上层应用阻塞等待。这个功能可以通过设置下面的3个超时参数、超时重试次数来实现。在超时的时候,立即主动断开,并重试。可以在当前集群上重试,也可以切换集

一款私有化部署的企业级在线文档和知识库

基础说明:无忧企业文档是JVS体系下的一款企业协同在线文档,主要服务客群为企业用户,解决企业内部文档编辑、知识沉淀、知识协同等痛点。项目主要采用Java开发,基础框架采用JVS(spring cloud+Vue)

Kafka消息延迟处理技巧,降低错误率

在评估Kafka消息延迟处理技巧的效果时,我们需要定义合理的实验场景和测试用例。确定实验数据的发送和接收方。设定实验场景,包括动作、触发条件和结果预期等。设定测试用例,包括性能验证、负载测试和容错测试等。

【RabbitMQ】RabbitMQ如何确认消息被消费、以及保证消息的幂等

消费者消费成功后会给MQ服务器的队列发送一个确认消息,此时会有一个回调检测服务监听该接收确认消息的队列,然将消费的消息写入数据库。以上是消息成功被消费时的流程,此时如果消费者没有将消息消费,就不会给服务器发送确认消息了,生产者隔一段时间会延迟发送与之前发送的一模一样的数据到另一个给回调检测服务监听的

IDEA创建SpringBoot+maven项目

9.引入相关依赖,配置application配置文件,将application.properties改为application.yml,也可以不改,不过如果application.properties存在,那么application.yml不会生效,application.yml的配置比applic

Flink动态ClickhouseSink+自动建表

通过自定义注解的形式,对JdbcSink进行封装,支持自动建表、自动拼接insert语句

什么是主数据?浅谈主数据的管理与应用

主数据是指满足跨部门业务,跨流程,跨主题,跨系统,跨技术,协同需要的、反映核心业务实体状态属性的组织机构基础信息,主数据具有权威性,全局性,共享性,扩展性等特点。

Kafka消息积压的原因和处理的方法

kafka消息积压

【面试需了解之消息队列】RocketMQ、kafka、RabbitMQ概述

消息队列说明:RocketMQ、kafka、RabbitMQ概述及关键概念

grafana+prometheus+pushgateway+flink可视化实时监控

grafana+prometheus+pushgateway+flink可视化实时监控

tp6安装并使用rabbitMQ

tp6 使用rabbitmq

Kafka安装、配置和使用

kafka的学习之路

Kafka详解

kafka是一款分布式、支持分区的、多副本,基于zookeeper协调的分布式消息系统。最大的特性就是可以实时处理大量数据来满足需求。Kafka 支持自定义规则,一个 Producer 可以使用自己的分区指定规则。

大数据开源框架环境搭建(七)——Spark完全分布式集群的安装部署

操作系统:Ubuntu 18.04Spark版本:2.4.0。

微服务 - Spring Cloud - Eureka Server单机和集群搭建、单机服务注册和集群服务注册

Eureka是Netflix开发的服务发现框架,本身是一个基于REST的服务,主要用于定位运行在AWS域中的中间层服务,以达到负载均衡和中间层服务故障转移的目的。SpringCloud将它集成在其子项目spring-cloud-netflix中,以实现SpringCloud的服务发现功能。

登录可以使用的更多功能哦! 登录
作者榜
...
资讯小助手

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈