• 在微服务设计过程中,经常出现的一个共同点和要求是共享共同数据。而这个问题在微服务之间的异步消息驱动通信(使用Kafka)中变得更加有趣了 例如,微服务1有一些数据。微服务2和3想要访问这些数据。 我看到了
  • 与其他现代大数据平台一样,Kafka 通过将数据分区到集群中的多个节点来实现无限的水平可扩展性。对于 Kafka,这意味着每个主题都有 1 个或多个分区。 主题拥有的分区越多,并发性就越高,因此潜在的吞吐量就越高。
  • 在本节教程中,我们将学习如何在 Spring Boot Kafka 项目中创建 Kafka Producer 和 Consumer  。Spring 团队 为 Apache Kafka 依赖项提供 Spring,以配合开发基于 Kafka 的消息传递解决方案。 在本教程中,我 icon
  • 异步编程在开发反应式和响应式应用程序方面带来了许多优点。然而,它也存在缺点和挑战,其中主要的问题之一是背压问题。 什么是背压?在物理学中定义是:它是与管道中所需的流体流动相反的阻力或力 icon
  • RabbitMQ: 基于Erlang构建 支持多种协议,包括AMQP、MQTT和STOMP。 以开发人员友好而闻名。 非常适合多个消费者的复杂路由。 Kafka: 基于Scala和Java icon
  • 我们将指导您完成将 Spring Kafka 集成到微服务架构中的过程。Spring Kafka 是将 Apache Kafka 的强大功能与 Spring 生态系统的优雅和便利连接起来的桥梁。 在您的项目中设置 Spring Kafka< icon
  • 使用kafka-native可以将Kafka 代理(和 Zookeeper)通过Quarkus 和 GraalVM 编译为本机原生代码。 项目结构 quarkus-kafka-server-extension:Quarkus 扩展包 icon
  • 使用spring modulith轻松地将选定的域事件外部化到消息代理:添加例如,Kafka集成模块选择要外部化的域类型(例如,通过使用(At)外部化) 点击标题见案例,展示如何自动将域事件外部 icon
  • Grab 是东南亚领先的超级应用平台,提供对消费者重要的日常服务。Grab 不仅仅是一款叫车和送餐应用程序,还在该地区提供广泛的按需服务,包括移动、食品、包裹和杂货配送服务、移动支付以及遍及 8 个国家 428 个城市的金融服务。 Grab 的实时 icon
  • 变更数据捕获是一个从数据库获取数据的过程,用于复制针对操作数据库执行的操作,以供下游应用程序使用。 CDC可用于将针对源数据库执行的事务移动到目标数据库。实时CDC在此非常有价值,因为它可以实现零停机源数据库复制和迁移。例如,在将为关键应用程序提供服务的内 icon
  • 事务为发布到 Kafka 的一组消息提供原子性、一致性、隔离性和持久性 (ACID) 的保证。这意味着要么事务中的所有消息都将成功写入 Kafka,要么不会写入任何消息。在确保数据一致性和避免任何数据丢失方面,这是一个至关重要的功能。 Kafka 事务在数 icon
  • OpenTelemetry Collector 和 Apache Kafka 之间的选择不是零和游戏。每个都有其独特的优势,甚至可以在某些架构中相互补充。OpenTelemetry Collector 擅长数据收集、压缩和过滤,使其成为减少系统内延迟并在数据到达后端之前提高数据质量的有力候选 icon
  • 在本文中,您将了解如何使用 Spring Boot 和 Open Telemetry 为 Kafka 生产者和消费者配置跟踪。我们将使用 Micrometer 库来发送轨迹,并使用 Jaeger 来存储和可视化它们。 Spring Kafka 内置 icon
  • Kafka Connect 的现代且直观的命令行客户端。 该项目是Kafka Connect的命令行客户端。依靠kubectl的习惯用法和语义,它允许您注册和检查连接器、删除它们、重新启动它们等。 这说明 icon
  • 数据管道中的数据合约是什么?如何实施? 最简单的数据合同是数据生产者和数据消费者之间就所生产的数据应是什么样子、应满足什么 SLA 以及其语义达成的协议。 数据合约是一种含有以下元数据结构: 生产 icon
  • 有了这个补丁,测试在5066毫秒内完成,结果性能提高了34%。在Kafka版本2.6.2的测试场景中,使用2K的数据包大小,导致10%的性能提升。 来自阿里Liu Song的测试:我在 32 核环境中进行了测试,启动 32 个并发线程对同一 icon
  • 在 Netflix,我们的会员和财务数据工程团队利用与计划、定价、会员生命周期和收入相关的各种数据来推动分析、为各种仪表板提供支持并做出基于数据的决策。 Netflix 财务报告中的许多指标均由我们团队的努力提供支持和协调!鉴于我们在这条关键路径上 icon
  • 这篇博文探讨了 2023 年保险行业的数据流状态。索赔处理、客户服务、远程信息处理和新业务模式的发展需要实时的端到端可见性、可靠且直观的B2B 和 B2C 通信,并与人工智能/机器学习等前沿技术集成以进行图像识别。数据流允许实时集成和关联任何规模的数据,从而以更具成本效益的方式改进保险行业的大多数业 icon