Kafka消息系统

     

一张图比较:RabbitMQ、Kafka和ActiveMQ

344
RabbitMQ: 基于Erlang构建 支持多种协议,包括AMQP、MQTT和STOMP。 以开发人员友好而闻名。 .

Linux 6.6 ext4提高Kafka性能34%

168

有了这个补丁,测试在5066毫秒内完成,结果性能提高了34%。在Kafka版本2.6.2的测试场景中,使用2K的数据包大小,导致10%的性能提升。 <.

Kafka 事务的一次性语义

192 4K

事务为发布到 Kafka 的一组消息提供原子性、一致性、隔离性和持久性 (ACID) 的保证。这意味着要么事务中的所有消息都将成功写入 Kafka,要么不会写入任何.

Spring Kafka教程指南大全

246 17K

我们将指导您完成将 Spring Kafka 集成到 .

从数据库导出数据CDC的几种方式

252
变更数据捕获是一个从数据库获取数据的过程,用于复制针对操作数据库执行的操作,以供下游应用程序使用。 CDC可用于将针对源数.

一张图解释数据合同如何实施

211
数据管道中的数据合约是什么?如何实施? 最简单的数据合同是数据生产者和数据消费者之间就所生产的数据应是什么样子、应满足什么.

kcctl:Apache Kafka Connect的命令行客户端CLI

167

Kafka Connect 的现代且直观的命令行客户端。 该项目是Kafka Connect的命令行客户端。依靠k.

东南亚Grab如何降低Kafka流量成本?

312 4K

Grab 是东南亚领先的超级应用平台,提供对消费者重要的日常服务。Grab 不仅仅是一款叫车和送餐应用程序,还在该地区提供广泛的按需服务,包括移动、食品、包.

Spring Modulith:模块内领域事件发给外部Kafka的示例

274 2K

使用spring modulith轻松地将选定的域事件外部化到消息代理: 添加例如,Kafka集成模块 选择要外部化的.

将Kafka和Zookeeper通过Quarkus和GraalVM编译为本地快速启动的原生代码

356 4K

使用kafka-native可以将Kafka 代理(和 Zookeeper)通过Quarkus 和 GraalVM 编译为本机原生代码。 .

使用 Vert.x 处理 Kafka 和数据库之间的背压

503 10K

异步编程在开发反应式和响应式应用程序方面带来了许多优点。然而,它也存在缺点和挑战,其中主要的问题之一是背压问题。 .

Spring Boot Kafka 生产者和消费者示例

479 1 9K

在本节教程中,我们将学习如何在 Spring Boot Kafka 项目中创建 Kafka Producer 和 Consumer  。 Spring.

跨微服务共享公共数据如何实现?

473 1

在 微服务 设计过程中,经.

使用Kafka并行消费者提高Apache Kafka性能

346 1 3K

与其他现代大数据平台一样,Kafka 通过将数据分区到集群中的多个节点来实现无限的水平可 .

Kafka的关键配置min.insync.replicas

395

Kafka的关键配置min.insync.replicas :用户消息生产的客户端配置,表示消息生产者认为写入成功之前确认收到记录的代理数量。 .

Apache Kafka能用于工作流编排引擎吗?

505 2K

BPMN或类似的流程图很适合于业务流程的建模。业务和技术团队很容易理解可视化的内容。它记录了业务流程,便于以后的修改和重构。各种工作流引擎解决了自动化问题:.

《KIP-932:Queues for Kafka》于7天前发布。

248

Kafka的队列Queues 是目前讨论的最热门的新功能! 传统的队列系统是这样一种系统: - 多.

使用Kafka 和 Spring Boot 实现并发编程

404 14K

本文将教您如何使用 Spring Boot 和 Spring for Kafka 为 Kafka 消费者配置并发。Spring for Kafka 的并发与.

在没有 zookeeper 的情况下运行 Kafka

329

Kafka在其 Kafka Raft Metadata 模式中使用 Raft 共识算法进行领导者选举,从而消除了对 ZooKeeper 管理集群元数据的依赖.

使用 Knative、Quarkus 和 Kafka 在 OpenShift 上实现无服务器

254

在 OpenShift 上构建和运行 Quarkus .

为什么 Apache Kafka 不需要 Fsync 来保证安全?

352 2K

Apache Kafka 不需要 fsyncs 来确保安全,因为它在其复制协议中包含恢复。它是一个真实世界的 .

盛宝银行基于数据网格的分布式领域驱动架构最佳实践

388 15K
这篇博客文章概述了如何 盛宝银行 .

Redis、Kafka 与 RabbitMQ 对比

680 2 3K
当为 微服务 使用 .

Bitcask - 日志结构的快速 KV 存储

764 2K

Bitcask 是最高效的嵌入式键值 (KV) 数据库之一,旨在处理生产级流量。向世界介绍 Bitcask 的论文称它是一个用于快速键/值数据的 .

ActiveMQ 与 Kafka 的比较 | redhat

510

将 ActiveMQ 与 Kafka 进行比较类似于将关系数据库与 NoSQL 进行比较。 ActiveMQ 不像.

如何探测不健康 Kafka 消费者并将其自动重启?

1064 6K
在 Cloudflare,我们采取措施确保我们在基础设施的各个层面都能抵御故障。这包括 Kafka,我们将其用于关键工作流程,例如发送对时间敏感的电子邮件和.

Kafka 如何实现低延迟? - foojay

985

大多数 Apache Kafka 基准测试似乎测试的是高吞吐量而不是低延迟。 Kafka 传统上用于高吞吐量而不是对延迟敏感的消息传递,但它确实具有低.

Apache Kafka在实时物流、运输行业运用

947 5K

物流、航运和运输需要实时信息来构建高效的应用程序和创新的业务模型,通过数据流支持相关的决策、建议和警报。 这篇博文.

使用Flink实现Exactly-Once分布式事务 - Devora

880 5K
分布式有状态流处理具有挑战性,尤其是在处理故障和恢复方面。在流处理中,最常被问到的问题之一是“我的流处理系统是否保证每条记录都被处理一次且仅一次,即使在处理.

一切都使用 Postgres

832

如何降低复杂性并加快行动速度? 使用 Postgres 作为 .