-
公开(公告)号:CN109218385A
公开(公告)日:2019-01-15
申请号:CN201810688267.2
申请日:2018-06-28
申请人: 西安华为技术有限公司
摘要: 本申请提供了一种处理数据的方法和装置,该方法包括:主应用获取该主应用和至少一个备应用中的多个客户端模块的标识信息;该主应用根据该标识信息确定第一客户端模块的第一预配置关系和第二预配置关系,其中,该第一客户端模块为多个客户端模块中的任意一个,该第一预配置关系用于指示该第一客户端模块从卡夫卡kafka系统中获取第一数据块的分区位置,该第二预配置关系用于指示该第一客户端模块将处理的所述第一数据块存储至该kafka系统中的分区位置。本申请实施例的技术方案,能够保证处理数据块时分区有序。
-
公开(公告)号:CN109218385B
公开(公告)日:2021-08-03
申请号:CN201810688267.2
申请日:2018-06-28
申请人: 西安华为技术有限公司
摘要: 本申请提供了一种处理数据的方法和装置,该方法包括:主应用获取该主应用和至少一个备应用中的多个客户端模块的标识信息;该主应用根据该标识信息确定第一客户端模块的第一预配置关系和第二预配置关系,其中,该第一客户端模块为多个客户端模块中的任意一个,该第一预配置关系用于指示该第一客户端模块从卡夫卡kafka系统中获取第一数据块的分区位置,该第二预配置关系用于指示该第一客户端模块将处理的所述第一数据块存储至该kafka系统中的分区位置。本申请实施例的技术方案,能够保证处理数据块时分区有序。
-