菲洛嘉青春动能素135HA FILLMED® NCTF 135HA LED指示灯的常见故障分析 智微智能 Elkhartlake K075终端,零售产业新选择 天空蓝拓客管理系统详细介绍版 muso公链项目 天使计划 是什么?[秘] 独家揭秘最前沿的家装“黑科技”——掌赋 天博体育欧洲杯特辑,东道主法兰西的失意2016 亚马逊的送货侦察员 学习听起来像挡泥板 Google Comics Factory使ML变得容易 笑着说-男性或女性 Amazon Rekognition中更好的人脸检测 关于Spaun的真相-大脑模拟 两个聊天机器人彼此聊天-有趣又怪异 GANPaint:将AI用于艺术 WCF和WF给予社区 从耳朵到脸 所有神经网络的深层缺陷 蠕虫在尾巴上平衡杆子 Kickstarter上的OpenCV AI套件 TensorFlow-Google的开源AI和计算引擎 众包取代新闻工作者 Google的DeepMind学会玩街机游戏 哑机器人V智能机器人 .NET与.NET 5融为一体 Google的深度学习-语音识别 LInQer将.NET LINQ移植到Javascript 机器人TED演讲-新的图灵测试? GAN的发明者加入苹果 您的智能手机会监视您键入的内容 人工智能帮助改善国际象棋 Zalando Flair NLP库已更新 TensorFlow 1.5包含移动版本 AlphaGo输了一场比赛-比分3-1 虚拟机器学习峰会 Microsoft开源AI调试工具 SharePoint走向移动 F#4.0发出文化变革的信号 克里斯蒂拍卖AI艺术品 人工智能如何区分 Facebook在蒙特利尔的新AI实验室 Mozilla想要您的声音 微软使用极深的神经网络赢得ImageNet 建立AI合作伙伴关系 .NET Core 3-Microsoft几乎回到了起点 神经网络-更好的销售商? Google使用AI查找您的住所 虹膜-适用于Android的Siri证明苹果没有优势 TensorFlow 2提供更快的模型训练 深度学习研究人员将为Google工作
您的位置:首页 >开发 >

Kafka 1变得更加宽容

Apache Kafka现在可以在1.0版中使用,因为它已经足够稳定以供企业使用。分布式流引擎的新版本更加容忍磁盘故障,支持Java 9,并且具有更好的指标。

kakfalogo

Apache Kafka分布式数据流引擎终于发布了1.0版,这是一个里程碑,表明该平台终于可以为主流业务做好准备了。Kafka是最初由LinkedIn开发的消息代理。然后将其捐赠给Apache并开源。它的优点是轻巧,可扩展且快速。与仅处理语言之间的消息和数据流交换的传统消息代理不同,Kafka提供了低延迟,高吞吐量,容错的发布和订阅管道,并能够处理事件流。它可以像消息传递系统一样发布和订阅数据流,高效,实时地处理数据流,并将数据流安全地存储在分布式复制集群中。

对新版本的改进包括:仅一次语义上的性能改进,具有Java 9支持的TLS和CRC32C实现显着更快,显着更快的受控关闭以及更好的JBOD支持。

一次精确语义的实现意味着,如果分布式系统中某处出现问题(可能是代理崩溃或网络问题),并且生产者重试发送消息,则该消息将只发送一次给最终消费者。这是理想的结果,但是很难实现,因为它需要消息传递系统本身以及生成和使用消息的应用程序进行协作。

新版本的另一个改进是Streams API。Kafka Streams是用于构建应用程序和微服务的客户端库,其中输入和输出数据存储在Kafka集群中。改进了Streams的构建器API,以隐藏内部方法。并且添加了新的API以在运行时公开活动任务的状态。还有一个新的联合组API,可用于处理状态存储较少和代码中移动部分较少的分区聚合。

另一个改进是Kafka更好地容忍磁盘故障的能力。到目前为止,尚未建议使用JBOD(仅磁盘捆绑)存储配置,因此需要RAID。在此发行版中,Kafka将更好地处理磁盘故障,从而使JBOD代理中的单个磁盘故障不会使整个代理崩溃。相反,代理将继续提供保留在正常运行的磁盘上的所有日志文件。

kakfalogo

郑重声明:本文版权归原作者所有,转载文章仅为传播更多信息之目的,如作者信息标记有误,请第一时间联系我们修改或删除,多谢。