BpFile(id=504, bpId=369, name=基于函数计算FC实现企业级权限精准控制Kafka跨实例消息同步, author=null, keyword=函数计算,Kafka,消息同步, description=基于阿里云函数计算FC实现同帐号阿里云Kafka实例之间消息、元数据同步,跨帐号阿里云Kafka实例之间消息、元数据同步,阿里云Kafka实例和IDC自建Kafka(其他云Kafka)之间消息、元数据同步。, position=null, ossUrl=bp-9D7AJ176RH0D0O64.pdf, tags=null, level=null, tagList=null, products=null, productList=null, hotspot=null, oneClick=1, createTime=null, modifiedTime=null, timeConsuming=null, status=1, pdfDescription=
应用场景
在大数据场景,企业的Kafka实例可能存在多种情况,比如使用阿里云Kafka服务,可能是自建开源Kafka,或者是其他云上的云Kafka。不同的业务使用不同类型的Kafka实例,在这个前提下Kafka实例之间可能会需要消息同步的情况:
同帐号容灾场景:比如Kafka实例都是阿里云Kafka,但是Kafka实例会有主备之分,需要将主Kafka实例的消息实时同步到备Kafka。
跨帐号或异地容灾:这类场景比如主Kafka是阿里云Kafka,备Kafka是IDC开源自建Kafka,或者是其他云上的Kafka。
不同业务之间消息同步:因为现在的业务通常不会是信息孤岛,都需要消息互通,所以可能是A业务的Kafka实例消息需要同步到B业务的Kafka实例,并且这两个Kafka实例归属不同的RAM角色,有自己独自的权限控制。
解决问题
解决使用开源组件做消息同步的高成本问题。
解决使用开源组件做消息同步的并发性能、稳定性问题。
解决使用开源组件做消息同步的可靠性问题(重试机制,容错机制,死信队列等)。
大幅提升构建消息同步架构的效率,降低构建复杂度问题。
, templateId=XNQFHZU6PPJ8BOQ3, freetry=, visitTime=null, visitCount=null, video_url=, buttonName=null, buttonUrl=null, targetId=XNQFHZU6PPJ8BOQ3, partner=, partnerUrl=, partnerLogo=, cooperation=, cooperationList=null)