文章 2022-02-16 来自:开发者社区

Pinterest开源Kafka集群自愈和工作负载均衡工具:DoctorKafka

Pinterest是一个进行图片分享的社交站点。他们使用Kafka作为中心化的消息传输工具,用于数据摄取、流处理等场景。随着用户数量的增加,Kafka集群也越来越庞大,对它的管理日趋复杂,并变成了运维团队的沉重负担,因此他们研发了Kafka集群自愈和工作负载均衡工具DoctorKafka,最近他们已经在GitHub上将该项目开源。 根据Pinterest的数据工程师Yu Yang的博客文章介绍,....

Pinterest开源Kafka集群自愈和工作负载均衡工具:DoctorKafka
问答 2022-02-15 来自:开发者社区

flink sql消费kafka各分区消息不均衡问题

flink sql消费kafka消息做数据同步,前期没有出现堆积不均的问题,这两天发现某些kafka分区积压特别多,会是什么原因造成的?怎样解决呢?从统计结果上看,消息还算均匀地打到各个kafka分区上。作业没有开窗和聚合,只是攒一批写一批这样子的。注:作业是跑在k8s上的 | 分区 ID | 客户端 | 最大位点 | 消费位点 | 堆积量 | | 0 | n/a | 155,397,108 .....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注