虽然一个好的设计可以最大限度地减少所需的通信量，但是在某些时候，线程之间的通信变得非常必要 （一个线程的工作是为你的应用程序工作，但是如果这个工作的结果从未被使用过，那么它有什么用处？）线程可能需要处理新的工作请求...

互联网技术高速发展的背景下，数据已经成为各大公司的最宝贵资源之一。大数据领域经过近十年的高速发展，无论是离线计算还是实时计算、不管是数据仓库还是数据中台都已深入各大公司的各个业务。在复杂业务的背景下，迫切需...

Kafka 客户端可以使用分区器依据消息的key计算分区，如果在发送消息时未指定key，则默认分区器会基于round robin算法为每条消息分配分区；

延迟消息就是字面上的意思：当接收到消息之后，我需要隔一段时间进行处理（相对于立马处理，它隔了一段时间，所以他叫延迟消息）。

我们之前的文章都是基于“裸机”系统，这种情况适合比较简单的示例，但如果我们要使用更先进的处理系统并最大限度地发挥 Zynq SoC 的双核 ARM Cortex-A9 MPCore 处理器的优势，我们需要一个操作系统。有很多系统可供选择：...

在实际的Flink 项目中，如何观察Flink的性能，如何监控Flink的运行状态，如何设置报警策略？下面简单讲下我的经验吧。

2.0.x的显著变化2.1.x的显著变化unclean.leader.election.enable 支持动态更新配置,以启用脏选举新增一个新的压缩方式 ：Zstandard 压缩(zstd),您必须升级代理和客户端才能使用它2.2.x的显著变化命令行工具可以使用 --...

导语 | 本文主要讲述如何使用golang基于Redis实现延迟消息队列组件。希望对有需求的同学有所帮助。一、背景业务中经常会有这样的场景：到期后自动执行指定操作；查询某个任务是否完成，未完成等待一定时间再次查询；回调通...

Flink自1.4.0开始实现exactly-once的数据保证，即在任何情况下都能保证数据对应用产生的效果只有一次，不会多也不会少。

这个过程涉及到 4 次上下文切换以及 4 次数据的复制，并且有两次复制操作是由 CPU 完成。但是这个过程中，数据完全没有进行变化，仅仅是从磁盘复制到网卡缓冲区。...