Kafka

Kafka分布式事件流平台,现为Apache开源项目。它以高吞吐、低延迟著称,每秒可处理数百万条消息,并支持数据持久化与多副本容错 。其核心架构基于主题(Topic)和分区(Partition),通过生产者(Producer)和消费者(Consumer)实现发布订阅模式,广泛应用于实时日志收集、消息队列、用户行为跟踪和流处理等大数据场景。
系统包含登录权限、组织与基础资料、业务单据与审批、数据统计看板、文件上传与第三方接口对接等模块。支持角色权限控制、条件检索导出、接口联调与分环境部署,满足企业内部日常业务处理与管理决策需求。
70Java企业服务
主要功能描述人员中心:员工/访客档案、人脸底图采集与质量检测、按组织维护(person模块+/wx/visitor),支持zip/Excel批量导入及导入结果回查(/importZip、/batchImport、/getImportStatus等路由)。黑名单管理:增删黑名单并强制下发全终端(版本号
90Java人工智能
本系统为大型跨国企业级数据中台,包含数据集成、数据开发、数据治理、数据服务四大核心模块。支持30+业务源系统数据接入,具备海量数据离线与实时处理能力。通过五层分层体系(ODS/DWD/DWS/ADS/APP)沉淀数据资产,提供数据地图、指标管理、标签画像、数据API服务等核心功能,支撑业财穿透与精细
100Python企业服务
系统以RAG知识库为核心,提供多租户、全渠道的智能客服能力。主要功能模块包括:知识库与知识上传管理、机器人配置(问答与流程)、会话与工单管理、坐席与人员权限管理、计费与额度、渠道集成与配置、运营数据看板;同时提供PC管理端、终端用户独立Web聊天页与微信小程序端三形态部署,支持跨域单点登录、语音渠道
120Python人工智能
智课仙境产品系统
主要包含学生,老师,同学的整体课堂。同学可以根据学生一起回答老师的问题,老师可以提出问题给学生,学生会根据老师提出的问题,然后对应的反问,同时学生也可以根据不同的场景提出不同的问题。设置不同的科目。根据学生的错题,系统会根据学生的题目进行靶向训练,提高学生的成绩。
120Python人工智能
一套可对接多业务场景的独立风控系统,由10+服务组成,覆盖公司全部业务关键环节:1、多场景统一接入:对接登录、注册、下单、领券、支付、评价等环节,业务线无需重复开发风控逻辑。2、规则配置化:规则与代码解耦,后台可配置条件、阈值、命中动作,改规则无需发版。3、高并发规则引擎:基于Aviator自研,上
210Java金融
聚合100+上游大模型与多模态服务商,提供智能路由、实时计量与多租户隔离;多租户与配额风控体系,构建Token多租户维度配额校验、频道级资源访问控制、团队层级与配额分配;支撑高并发实时计量、配额管控与账单结算。
280Kafka工业互联网
系统按RBAC划分权限:商品接口区分公开浏览与ADMIN读写,订单接口仅本人可见。核心模块包括商品管理(浏览、新增、编辑、上下架)、下单(多商品购物车、事务内扣减库存、订单号生成、下单价格快照)、订单管理(列表、详情、取消并回滚库存)。并发安全通过JPA@Version乐观锁实现,冲突时返回409提
310Java开发工具
1. 多数据源抽取,MySQL等源数据接入;2. ETL转换:字段清洗、格式转换、去重、数据质量校验;3. 定时任务调度,任务监控、失败告警、自动重试;4. 统计指标计算,生成报表;5. 报表接口,支持前端展示,邮件推送日报。
360Java低代码
1. 对接数据服务总线,消费上游推送业务数据;​2. 数据校验、脏数据剔除、字段清洗、线索规则过滤;​3. Kafka消息异步解耦,数据写入MySQL+ES;​4. 提供REST查询接口,支持多条件线索检索、批量数据导出;​5. XXL-Job定时任务,异常数据日志留存、失败重试。
310Java云计算
skywalking APM产品系统
1.业务监控2.资源监控3.AI助理4.基线告警5.整体业务或单笔业务的调用拓扑可视化6.业务交易性能大盘7.业务交易性能监控、告警8.提供debug级生产问题排查参考
310Java云计算
交易所产品系统
•参与直播及短视频系统后端开发,负责直播间管理、弹幕互动、礼物打赏、用户互动等核心业务模块•负责直播平台部分核心业务模块的设计与开发,持续进行系统性能及稳定性优化•参与直播消息分发系统设计与开发,基于WebSocket+Kafka构建实时消息推送体系,支持弹幕、礼物、用户进出等实时互动消息•负责直播
280Java区块链
json解析转换器,支持分布式高并发,支持百万级别访问。用于快速进行json的解析与对象转换。原有的开源工具,要么安全性不够,要么性能不够强悍,要么不支持定制,很难满足企业日益严苛的业务需求。开发的这个json解析转换器,可以同时满足以上三种需求。
260Java企业服务
1.内容与会员服务:书籍精华解读(音/视频)的内容生产、发布、搜索与订阅,会员权益与订单管理;2.微服务业务支撑:用户、内容、订单、营销活动等业务域拆分,提供服务注册发现、统一配置管理、服务网关与鉴权;3.研发效能平台:覆盖"开发/测试→集成/发布→生产运行→监控/报警→性能管理"全生命周期,包含质
290Java教育校园
后台稽核模块是系统的核心,采用消息驱动架构,整体流程如下:1.数据同步:用户先在网络成本分析系统中上传对应的附件与结算数据,数据经RocketMQ发送到后台,后台据此与用户端系统的数据进行比较;2.数据过滤:接收消息后进行过滤,剔除已废弃、已稽核过的单子,避免对同一条数据及废弃单据重复稽核;3.行为
370Java项目任务
本数仓平台完成整套ODS‑DWD‑DWS‑DM分层建设。ODS层对接各个业务系统原始数据;DWD层做数据清洗、脏数据过滤;DWS层做业务主题聚合;DM层面向报表业务,输出营业、销售、库存、客流主题数据集。支撑财务对账、门店经营分析、库存消耗统计等业务功能,对外提供指标查询数据源。
410Java电商
1.数据治理与中台建设:落地DAMA方法论,完成数据资产目录、数据标准与模型设计,通过ETL将财务、人力、生产、设备等多域数据入湖至数据中台。2.作业成本法(ABC)应用:基于治理后的数据实施ABC成本法,构建数仓分层、指标开发及驾驶舱,实现财务成本的深度穿透分析。3.AI智能体集群:部署AIAge
370Python企业服务
实时数据大屏产品系统
1.实时采集模块:通过flink-cdc实时采集业务数据库binlog,将数据写入kafka队列2.票务实时计算模块:flink实时接收kafka数据,按放映日期实时计算影片票房、影院票房、观影人次、排片效率等指标3.卖品实时计算模块:通过flink实时计算影院卖品实时销量指标4.会员实时计算模块:
290Java企业服务
七维系统交易产品系统
系统每天定时自动扫描A股全市场,从技术面、资金面、政策面等多个维度给每只股票打分并排序;自动识别K线形态,分析量价配合情况;当多个指标同时向好形成共振时重点推荐,出现明显分歧时给出风险提示;最后把结果生成简洁的邮件报告,推送选股名单、持股周期参考和离场提示,用户打开邮箱就能看懂当天该关注什么、该避开
520Python金融
筑巢荟产品系统
筑巢荟是一个面向室内设计与建筑装饰行业的综合性服务平台。项目旨在打破设计师之间的信息壁垒,整合分散的优质设计资源,为设计师、设计机构及行业从业者提供设计交流、专业学习、资源互通与品牌展示等功能。通过搭建线上互动与线下活动相结合的服务体系,帮助设计人才提升专业能力、拓展行业视野,促进设计资源与业务机会
420Java工业互联网
当前共372个项目more
×
寻找源码
源码描述
联系方式
提交