Kafka

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