Kafka-on-Pulsar 实现了偏移更好支持kafka - StreamNative

KoP(Kafka on Pulsar) 2.8.0 支持连续偏移,现在可以投入生产。 默认情况下,Pulsar broker 只支持 Pulsar 协议。通过协议处理程序,Pulsar

2 年 前

Kafka如何实现实时流处理 Part 1 - André Melo

Apache Kafka可能主要被称为消息传递中间件,其结构比队列更灵活,但它也使团队能够更低地进入实时数据管道。 使用Kafka的所谓流应用程序具有可 扩展性 ,容错性,并且显示强大的排序和

4 年 前

Coinbase如何改造基础设施中Kafka?

在2020年和2021年,Coinbase的数据团队在AWS MSK、开源的Kafka Connect和Airflow ETL的基础上塑造了一个通用的Kafka基础设施,以增强工程师对事件流、数据

1 年 前

Apache Kafka 3.0.0发布

Apache Kafka社区宣布 Apache Kafka 3.0 的发布。Apache Kafka 3.0 是一个多方面的主要版本。Apache Kafka 3.0 引入了各种新功能、突破性的

2 年 前

删除Kafka无用主题可提升40%性能

linkedin启动TopicGC删除Kafka不用的topic后,已经删除了近20%的topic,大大降低了Kafka集群的元数据压力。客户端请求性能提高了 40% 左右,CPU 使用率降低了

1 年 前

在事件驱动管道中设计弹性系统

我为我们的金融科技软件设计了事件驱动的 架构 。它由三个部分组成。 第一部分有一个同步过程, 第二部分和第三部分有 异步 操作。响应回复客户端后,将Kafka(消息代理)的最终结果发送到

1 年 前

使用Apache Kafka实现Event sourcing与CQRS

状态更改重新建模为对日志中事件的响应。这里讨论Kafka Streams将如何帮助将 事件溯源 和 CQRS 付诸实践。 我们来举个例子。考虑一个Facebook的社交网络应用程序(尽管是一个

7 年 前

Kafdrop是Apache Kafka的开源Web UI可视化界面 - Emil Koutanov

作为消息传递平台,Kafka无需介绍。自成立以来,它实际上重写了有关事件流的书,并促进了现在的家庭 设计模式 的采用-微服务,事件源和 CQRS 。 作为一个天赐之物,它几乎以其臭名昭著的

4 年 前

基于Spring Integration的Apache Kafka JMS消费者

让我们总结一下从Apache Kafka编写JMS消费者时需要知道的基本功能: Kafka没有跟踪哪些消息被消费而言,Apache Kafka是无状态的。这是JMS消费者的责任。这种简单性使

5 年 前

Zilla:一个事件驱动的API网关

 Zilla是一个用于事件流的开源 API 网关,Zilla 使用标准协议(例如 HTTP、Server-Sent Events 和 Kafka)将 Web 和移动应用程序连接到事件驱动的 微

1 年 前

Kafka 如何实现低延迟? - foojay

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

1 年 前

Apache Kafka优化部署的十大最佳实践

本文分享Kafka最佳实践可以使得管理这个功能强大的数据流平台变得更加容易,而且更加有效。以下是十个有助于保持Kafka部署优化并更易于管理的特定提示: 设置日志配置参数以保持日志可管理

5 年 前

从反应式角度看Apache Kafka

消息主干一样行动。我们将在这里研究的消息代理是Apache Kafka。 介绍Apache Kafka Apache Kafka 是一个众所周知的分布式流媒体平台。它旨在实现线性可扩展

5 年 前

flight-tracker-demo:一个Quarkus + Kafka演示源码项目

这个实时航班跟踪器演示展示如何使用Quarkus + Kafka架构,项目点击标题进入: 安装: 从存储库的根目录: 运行./mvnw clean install -pl

1 年 前

topicctl:Kafka主题声明式管理工具

用于轻松、声明式管理 Kafka 主题的工具。包括从 YAML “应用”主题更改的能力,以及用于对代理、主题、消费者组、消息等进行交互式探索的 repl。 通过标准工具管理 Kafka 主题可能

1 年 前