最新 最热

面试如何保证数据一致性问题

面试redis和DB数据一致性问题,也是经常被问到的,只要你建立写了redis,如果面试官想问一些场景问题,都会扯到数据一致性问题,今天我们就解读一下这个问题,按照以下思路解读...

2022-12-01
1

MQ消息丢失问题

消息中间件消息丢失问题,由于本人只用过rabbitmq和kafka,就这两种中间件简单说明一下

2022-12-01
1

面试-Zookeeper作为注册中心合适吗

这个是某公司的面试题,之前没有考虑到这个问题,只知道zk如何做注册中心,很少考虑合不合适问题,因为大家都这么用

2022-12-01
0

使用ogg实现oracle到kafka的增量数据实时同步

源端和目标端的文件不一样,目标端需要下载Oracle GoldenGate for Big Data,源端需要下载Oracle GoldenGate for Oracle!

2022-12-01
1

k8s快速部署kafka 3.3.1

在平常开发测试中,使用docker或者k8s快速部署某个组件会是一个不错的选择。kafka 3.3.1作为kraft第一个生产可用版本,本文介绍使用k8s快速部署基于kraft运行的kafka 3.3.1。...

2022-12-01
1

P2项目答辩总结

​ 将每次签到的记录保存在redis中,判断保存的数量,有多少个,就连续签到多少天;

2022-12-01
1

重磅!Apache Kafka 3.3 发布!

我们很自豪地代表 Apache Kafka 社区宣布发布 Apache Kafka® 3.3。3.3 版本包含许多新功能和改进。这篇博文将重点介绍一些更突出的功能。有关更改的完整列表,请务必查看发行说明。...

2022-12-01
1

消息队列|RabbitMQ入门概述

有一个大的系统由A系统和B系统组成,A系统先将数据发送给MQ,然后MQ将数据发送给B系统,实现A系统和B系统之间的数据传输。A系统生产数据,称为生产者。B系统消费数据,称为消费者。MQ为存储数据的消息中间件。...

2022-12-01
1

Flink流处理API大合集:掌握所有flink流处理技术,看这一篇就够了

在之前的文章中有提到过,一个flink应用程序开发的步骤大致为五个步骤:构建执行环境、获取数据源、操作数据源、输出到外部系统、触发程序执行。由这五个模块组成了一个flink任务,接下来围绕着每个模块对应的API进行梳理...

2022-12-01
1

Redis生产者与消费者

生产者的任务就是将消息添加到Redis的Sorted Set中。首先,需要计算出消息添加到Redis的SlotKey,如果发送方指定了消息的slotBasis,则计算slotBasis的CRC32值,CRC32值对槽数量进行取模得到槽序号,SlotKey设计为#{topic}_#{i...

2022-12-01
1