- 博世苏州ADAS团队数据平台组面试题--kafka消费超时会发生什么?
-
背景??kafka消费者采用批量拉取的方式，一次拉取一批记录来消费，如果消费者线程消费超时会导致整批消息的回滚，从而导致已经消费过的数据再消费一遍，消费者不幂等会出大问题，这也是为啥要强调使用消费队列...
- uncode-mq 基于netty的轻量级java消息中间件
-
功能特点消息存储速度非常快速。使用简单方便，目前只支持topic方式。依赖java环境。说明：目前只在部分项目中使用，欢迎学习交流。模块架构说明：集群由多个Group组成一个队列，每个Group由Ma...
- 分布式 ID 生成系统 Leaf 的设计思路，源码解读
-
今天来分享下最近研究的分布式ID生成系统...
- Kafka系列文章之安装测试-第2篇 kafka测试命令
-
?前言上篇文章讲解了Kafka的基础概念和架构，了解了基本概念之后，必须得实践一波了，所谓“实践才是检验真理的唯一办法”，后续系列关于Kafka的文章都以kafka_2.11-0.9.0.0...
- Zookeeper : 源码入门 zookeeper底层实现原理
-
一.前言出于对集群选举流程的好奇,所以把Zookeeper源码拉下来跑了一下,这篇文档对这个过程做一个简单的记录.要想看懂任何源码,第一步就是要跑起来.这一篇主要介绍,如果快...
- 分布式开源调度框架TBSchedule原理与应用
-
主要内容：第一部分TBSchedule基本概念及原理1.概念介绍2.工作原理3.源码分析4.与其他开源调度框架对比第二部分TBSchedule分布式调度示例...
- zookeeper入门-安装启动常用操作及案例
-
简介最近做的项目用的是zookeeper+kafka，大致学习了下zookeeper。像Spring有IOC和AOP一样，zookeeper的核心主要是文件结构和监听机制安装Zookeeper的安装...
- 基于zookeeper和quartz实现分布式定时调度
-
利用zookeeper的特性，来控制quartz实现分布式调度，保证quartz的单点运行，同时解除quartz自身分布式部署对数据库的依赖，保证同一时刻只有一个quartz应用在执行任务。实现方式利...
- 分布式系统搭建实战(下) 分布式架构搭建
-
一、部署前准备1.1部署文件清单1.2部署架构图1.3服务器资源准备、检查及预装二、消息队列ActiveMQ部署及策略2.1ActiveMQ单点部署2.2ActiveMQ...
- 程序员早班车:3分钟入门Zookeeper
-
ZooKeeper是一个典型的分布式数据一致性解决方案，分布式应用程序可以基于ZooKeeper实现诸如数据发布/订阅、负载均衡、命名服务、分布式协调/通知、集群管理、Master选举、分布式...