最新 最热

RocketMQ 基础入门

RocketMQ是一个统一消息引擎,轻量级的数据处理平台。通俗的讲,当你需要一个消息处理框架,可以考虑选它。

2022-03-09
0

Kafka分区与消费者的关系kafka分区和消费者线程的关系

kafka中的topic可以细分为不同的partition,一个topic可以将消息存放在不同的partition中。

2022-03-09
0

中华石杉Java面试突击第一季笔记一(消息队列)

数据结构和算法,软素质,工程素养,履历背景,学历,带团队管理,技术广度、技术深度、项目经验、系统设计

2022-03-09
1

基于Flink+State开发的实时订单

实时订单开发,说实话,最近开发,掉了一半的头发,复杂度,我就点到为止,还是希望大家多看看flink,这个可是开发利器。写这篇文章的目的,就是给大家分享一下实时订单的开发思路和遇到问题如何去解决。我就写的比较简单点,很多花里...

2022-03-09
1

客快物流大数据项目(六十):将消费的kafka数据转换成bean对象

目录将消费的kafka数据转换成bean对象一、将OGG数据转换成bean对象二、​​​​​​​将Canal数据转换成bean对象三、完整代码将消费的kafka数据转换成bean对象一、​​​​​​​将OGG数据转换成bean对象实现步骤:消...

2022-03-09
0

客快物流大数据项目(五十九):定义解析kafka数据的Bean对象类

根据数据来源不同可以分为OGG数据和Canal数据,两者之间有相同的属性:table,因此将该属性作为公共属性进行提取,抽象成基类

2022-03-09
0

【事件驱动架构】专家组:事件驱动的大规模架构

赖斯:欢迎来到我们关于架构的专题小组,你们一直想知道轨道。该专题小组称为事件驱动的大规模架构。当您思考事件驱动架构时,您会想到什么?这是规模、性能和灵活性的好处吗?也许你想到了一个你可能经历过的特殊问题。也许你...

2022-03-08
0

「Kafka技术」Apache Kafka中的事务

在之前的一篇博客文章中,我们介绍了Apache Kafka®的一次语义。这篇文章介绍了各种消息传递语义,介绍了幂等生成器、事务和Kafka流的一次处理语义。现在,我们将继续上一节的内容,深入探讨Apache Kafka中的事务。该文档的...

2022-03-08
0

【分布式】资源与事务:可观测性的基本二重性

西格曼:我叫本·西格曼。我是Lightstep的联合创始人兼首席执行官。我在这里讨论的是资源和事务,这是可观察性的一个基本的二元性。我职业生涯的大部分时间都在研究可观察性。在我职业生涯之初,我在谷歌工作了九年,致力于...

2022-03-08
1

【消息中间件】Redis vs Kafka vs RabbitMQ

对微服务使用异步通信时,通常使用消息代理。代理确保不同微服务之间的通信可靠且稳定,消息在系统内得到管理和监控,并且消息不会丢失。您可以从几个消息代理中进行选择,它们的规模和数据功能各不相同。这篇博文将比较三种...

2022-03-08
1