Kafka

Kafka分布式事件流平台,现为Apache开源项目。它以高吞吐、低延迟著称,每秒可处理数百万条消息,并支持数据持久化与多副本容错 。其核心架构基于主题(Topic)和分区(Partition),通过生产者(Producer)和消费者(Consumer)实现发布订阅模式,广泛应用于实时日志收集、消息队列、用户行为跟踪和流处理等大数据场景。
后台稽核模块是系统的核心,采用消息驱动架构,整体流程如下:1.数据同步:用户先在网络成本分析系统中上传对应的附件与结算数据,数据经RocketMQ发送到后台,后台据此与用户端系统的数据进行比较;2.数据过滤:接收消息后进行过滤,剔除已废弃、已稽核过的单子,避免对同一条数据及废弃单据重复稽核;3.行为
370Java项目任务
本数仓平台完成整套ODS‑DWD‑DWS‑DM分层建设。ODS层对接各个业务系统原始数据;DWD层做数据清洗、脏数据过滤;DWS层做业务主题聚合;DM层面向报表业务,输出营业、销售、库存、客流主题数据集。支撑财务对账、门店经营分析、库存消耗统计等业务功能,对外提供指标查询数据源。
410Java电商
1.涉及20+业务数据源,包括存货、收入、分摊、认款、报销等等2.每个数据源配置不同的凭证模板、科目映射,通过规则动态生成财务凭证3.大量自动化任务处理,包括结转,坏账计提,成本预提,损益合并等等4.凭证可实时生成,高吞吐量设计,配合Doris,kafka可以实现每秒6000-10000张凭证生成,
730Java项目任务
诉求工单上报(可附图)、状态机流转、全链路日志、进度可查智能派单一句话识别类目/紧急度;规则筛候选;Agent按评分/负载/新商优选并给理由;管理员采纳或改派服务预约开锁/修鞋/家电等类目预约上门,服务商履约服务商入驻审核、师傅管理、类目与档案;变更自动同步派单知识库内容治理公告、活动报名签到、业主
800Java政务
微服务组件:注册中心、配置中心、网关、接口监控、限流、Feign服务调用。基础服务:统一权限、支付、短信、推送、图片、定时任务、APP-API,以及设备管理与IoT接入。运维支撑:Hystrix监控、Zipkin追踪、Kibana日志、RabbitMQ业务消息、MQTT设备通道、自动化发布,覆盖开发
770Java企业服务
建设飞行计划风险评估和航前风险评估功能,围绕人员、航空器、环境、任务安排及排班冲突等因素开展综合风险分析,形成风险等级、评估结论及报告,实现飞行任务风险识别、预警和闭环管理,提升低空飞行安全保障能力。
1060Java项目任务
系统面向社区论坛与内容分发场景,支持用户注册登录、发帖评论、点赞投票、热榜推荐等核心功能。针对高并发访问场景,引入Redis缓存、Kafka消息队列及Lua脚本优化系统性能,实现异步削峰、排行榜计算及投票原子化处理,有效提升系统吞吐量与稳定性,满足互联网社区业务对高性能与高可用的需求。
820Kafka企业服务
嘉浏智慧高速产品系统
平台拆分20个微服务模块,覆盖基础权限、文件管理、监测数据接收消费、报警推送、MEC雷视融合数据分发等支撑模块,四大核心业务功能:车道级交通态势实时监测与智能调控,最大化单车道通行效率;AI自动识别道路突发事件,实现秒级预警、多方联动协同应急;道路设施全生命周期数字化养护管理,以预判式小修替代集中大
1380Java项目任务
智慧安防系统产品系统
基于智能门禁、智能锁控、电子围栏等智能化物防、技防设备设施,从源头上实现生产作业现场危险区域及危险源的有效隔离;利用人员定位、智能穿戴、环境监测等智慧感知设备实现生产现场安全风险隐患的提前预警,阻断事故链条,基于软的流程管控、硬的物理隔离、作业风险辨识、视频AI巡视等多源数据融合,虚拟与现实结合,线
820Java项目任务
海外现金贷产品系统
1.产品管理-支持灵活配置不同信贷产品(现金贷、分期贷、循环贷、企业贷),每个产品可独立配置额度范围、期限、利率、还款方式、费用结构2.进件管理:用户提交借款申请后的完整流程管理,包括资料采集、初审、终审、签约、放款全链路3.额度管理:基于用户画像和风控结果,管理用户授信额度、临时提额、额度恢复、额
950Java金融
1.该项目支持了保全的全部流程:申请,资料填写,人工或自动审核,结案。2.留存变更记录,并且同步保单,客户,保费的信息。3.同时部署了hive数仓,可以结合python脚本,生成可视化的excel,方便高效运营。
1000Java企业服务
某领域QB数据资源体系建设系统为涉密重点工程,搭建全生命周期数据管理体系,形成“采集—清洗—治理—应用”一体化闭环,包含五大核心功能模块。数据采集汇聚模块,支持多格式、多方式数据接入,兼具数据监控、采报、引接与管理能力,适配海量异构数据汇聚更新。智能数据治理模块,依托整编工作台、治理及模型引擎、数据
1120Java项目任务
多源时空分析西安市局综合性数据分析平台,贯通数据采集、治理、分析、应用全流程。依托WiFi信令海量数据实时运算处理,完成数据规整与深度研判,可精准甄别重点目标、开展动态管控。共有七大功能模块:案件中心统筹案件相关数据,消息中心推送各类动态讯息,查询中心支持多维度信息检索,数据监测中心实时把控数据态势
1160Java企业服务
增长分析平台产品系统
看板相关开发1.看板订阅、共享功能开发:指定给指定的角色进行阅读/编辑。2.看板的邮件推送开发:将看板推送给指定的账号。3.第三方看板的嵌入开发:嵌入第三方的看板。(如:Metabase看板)......分析工具开发1.KPI分析开发:分析某个事件(单事件)某个维度下指标的趋势。可以查看对应的同比、
1110Java项目任务
1,后端系统通过kafka实时接收jira平台的数据,rocketmq接收发布平台、故障平台等相关数据通过restfulapi接口主动拉取hr平台组织架构及出勤数据通过webhook方式获取gitlab代码仓库数据以MySQL数据库存储相关数据2,前端系统主要分为排期、实际输出、质量、效率、人员管理
770Java项目任务
全流程数字化管理,让断面计算更高效。工程管理:支持创建、复制、授权、导出模板,一站式管理工程项目全生命周期。断面数据处理:Excel批量导入纵断面/横断面数据,图片在线管理,深泓点自动计算,库容曲线可视化展示。断面计算:17项基础参数精细配置,一键执行计算,实时生成纵断面/横断面线形图,库区比降自动
1720Java项目任务
对海仿真平台产品系统
守护进程模块:负责本机信息与进程状态的实时监视、异常维护,同时承担想定数据的接收与规范化管理,并按要求持续上报本机运行状态数据。仿真控制服务模块:完成仿真控制界面的后端逻辑开发,通过优化数据交互链路,实现前端控制界面与数据库、仿真系统的低延迟、高可靠交互。态势服务模块与对外数据交互模块:完成两大模块
1430C++项目任务
智能对讲系统服务端重构项目:基于Java技术栈重构原C++服务端,实现实时语音通信系统核心能力,包括:-实时语音对讲-TCP/UDP网关服务-用户与群组基础服务
1230Java项目任务
校园二手平台产品系统
本项目是一个基于PythonWeb技术开发的在线信息管理与展示系统,部署在云平台上,支持用户通过浏览器进行访问和操作。系统主要包含信息录入模块、数据展示模块和基础管理功能,用户可以通过表单提交相关信息,并实时查看已录入的数据内容。项目实现了前后端数据交互、页面动态更新及数据持久化存储,具备轻量级后台
1160C++企业服务
ADMA(ApplicationDataManagementArchitecture)是*兴通讯基于Hadoop集群构建的应用数据管理框架,旨在实现大数据平台的数据治理能力。ADMA作为大数据调度平台,旨在集合业务元数据管理、任务血缘分析、任务监控、任务调度、业务资源管理、业务权限管理、业务优先级管
1630Python项目任务
当前共36个项目more
×
寻找源码
源码描述
联系方式
提交