Kafka

Kafka分布式事件流平台,现为Apache开源项目。它以高吞吐、低延迟著称,每秒可处理数百万条消息,并支持数据持久化与多副本容错 。其核心架构基于主题(Topic)和分区(Partition),通过生产者(Producer)和消费者(Consumer)实现发布订阅模式,广泛应用于实时日志收集、消息队列、用户行为跟踪和流处理等大数据场景。
对海仿真平台产品系统
守护进程模块:负责本机信息与进程状态的实时监视、异常维护,同时承担想定数据的接收与规范化管理,并按要求持续上报本机运行状态数据。仿真控制服务模块:完成仿真控制界面的后端逻辑开发,通过优化数据交互链路,实现前端控制界面与数据库、仿真系统的低延迟、高可靠交互。态势服务模块与对外数据交互模块:完成两大模块
320C++项目任务
1,使用了RBAC系统权限,oauth2.0,第三方集成登录。2,使用了DDD设计。使用了CI/CD集成部署流程3,使用了消息中间件,异步锁等解决分布式,提高系统的健壮性。
270Java企业服务
买家中心,卖家中心,站内信,切换城市,IP判断城市,手机号登录注册,便民服务查看购买,全文搜索,便民服务搜索,商品搜索,买家评价,统计满意率,客服版便民服务,定时任务更新索引,电商与ecif交互,客服反馈买家,预约回访,健康管理,退款管理,客服版健康管理,促销奖品设置注册奖品,首单奖品,双周奖,双月
320Java金融
1、项目包含模块:大数据计算模块,爬虫标准化模块,API模块,管理系统模块2、项目功能:(1)大数据计算模块:根据用户的观影数据,及该影视作品的标签,计算出用户的喜好,并打上标签。根据不同媒资的标签,计算出相似内容用于相似推荐。(2)爬虫标准化模块:根据局方提供的媒资基础信息,去爬取网络,完善其各项
320Java企业服务
ADMA(ApplicationDataManagementArchitecture)是*兴通讯基于Hadoop集群构建的应用数据管理框架,旨在实现大数据平台的数据治理能力。ADMA作为大数据调度平台,旨在集合业务元数据管理、任务血缘分析、任务监控、任务调度、业务资源管理、业务权限管理、业务优先级管
320Python项目任务
1.车辆数据实时接入:支持百万级车辆实时数据上报、采集、校验与清洗。2.大数据存储与计算:海量历史数据存储,日增量3–5T,支持高并发查询。3.Web管理平台:完整后台管理、车辆监控、数据查询、报表统计、权限管理。4.实时监控大屏:车辆状态、运行指标、异常告警可视化展示。5.AI智能分析:接入LLM
380Java企业服务
系统核心分为Java后端服务、Vue前端管理平台、PythonAI模型服务三大模块:后端基于SpringBoot搭建,实现用户权限管理、标注任务分配、标注数据存储、项目进度管控、数据导出等核心功能,支持多用户协同标注;前端基于Vue3实现可视化标注界面,支持矩形框、多边形标注、标注结果审核、标注历史
370Java工业互联网
1、核心痛点解决:官方spring-kafka仅支持单一Kafka集群配置,本项目完美解决项目中需要对接单个或多个Kafka集群的场景需求。2、三大核心能力:a)多集群灵活配置支持单一集群或多集群同时配置支持多种安全策略(SASL认证、SSL证书认证、宽松认证等)可动态启用/禁用特定集群配置支持主配
410Java开发工具
gocrypt交易所产品系统
全功能的数字货币交易所平台,包含功能:1.交易对管理2.行情系统3.自主研发撮合系统,提供高速内存撮合4.钱包系统5.主链对接、管理6.后台管理系统
320C++区块链
ai-matrix产品系统
1.模型层:-**框架**:AppleMLX(https://github.com/ml-explore/mlx)-**模型**:支持32B/70B级别本地模型-**优化**:ContinuousBatching、KVCache优化、显存分片2.AgentRuntime3.编排层4.Gateway:
310Python人工智能
1.基于DockerCompose,一键部署包含Kafka、Flink、Paimon的完整测试集群2.实现实时数据从Kafka接入,通过FlinkSQL进行清洗转换,并实时写入Paimon数据湖3.验证Paimon的流批一体读写能力,支持分钟级延迟的实时查询4.编写了详细的部署文档和验证脚本
710Java企业服务
本系统提供完整的充电桩管理解决方案,核心功能包括:设备注册与管理、用户扫码充电、订单推送与结算。支持实时监控设备状态、远程启停充电、故障告警通知,并提供用户账户管理、充电记录查询、多种支付方式接入及数据统计分析,助力运营方高效管理充电网络。
550Java工业互联网
合约撮合引擎:高性能分布式撮合与账务系统,负责订单撮合、持仓计算、清算与持久化。1、基于RPC框架构建微服务化架构,实现撮合、清算、推送、账务等模块的解耦与高效协同。2、使用Kafka作为高吞吐、低延迟的消息队列,将成交、清算等核心事件异步通知给下游的数据库写入、推送模块,实现系统解耦;3、使用My
730C++金融
1、策略下发与执行支持服务端策略下发到客户端客户端解析并执行本地策略支持30+策略模块独立编译+热更新插件化设计(策略解耦)动态扩展能力强2、多用户隔离机制每个登录用户启动独立Agent基于sessionBus实现用户级策略隔离多用户同时登录互不影响权限隔离(root/user)3、跨进程通信与系统
570C++企业服务
移动反诈功能主要涵盖智能预警、家人守护、保险补偿与技术反制四大核心维度,具体功能分点介绍如下:智能识别与预警:基于AI、大数据及大模型技术,系统能实时监测并识别诈骗电话和短信。当用户接到疑似诈骗电话时,会通过霸屏提醒、语音警示或闪信等方式进行强干预预警,提醒用户注意防范。亲情联防与远程守护:针对老人
610Java企业服务
im即时通信产品系统
1.我负责用go,写即时通信所有功能,除了游戏俱乐部,登录,注册,单聊,群聊,语音,朋友圈等功能,管理俱乐部等功能2俱乐部可以设置游戏规则,开游戏房间,控制房间规则,组队玩法,排行榜等
770Kafka项目任务
非攻工控平台产品系统
包含用户管理、示教系统、报警系统、机电控制系统(倍福、西门子、基恩士等)、视觉(相机+算法)系统、系统配置、数字孪生系统、QT平台、数据中心、以及OpenTelmetery等非业务模块
670C++工业互联网
该项目是一个为某省打造的网络安全认证系统,作为网络安全架构的核心组成部分,处理用户访问请求,提供全面的验证、授权和账户管理服务,覆盖产品规划、研发、销售和售后等多个业务板块
560C++政务
本平台专为规模化研发团队打造,提供一站式集成化解决方案,全面覆盖项目管理、需求跟踪、设计资产与文档中心四大核心模块。通过统一的工作流引擎,实现需求从提出、评审、开发到上线的全生命周期可追溯,确保团队目标对齐、进度透明。项目管理模块支持敏捷与瀑布多种模式,灵活适配不同团队节奏,提升任务分配与协作效率。
470Java汽车
派派产品系统
1.社交互动语音房间:多人实时语音聊天、K歌、话题讨论,支持500人同时在线。家族系统:创建/加入家族,参与家族战、团战,共享奖励与福利派派。个人主页:自定义头像、签名、相册,展示动态与成就。即时通讯:文字、语音、图片、表情,支持单聊与群聊。2.游戏化玩法(核心)抢红包/偷红包:好友间抢现金红包,是
1030Shell游戏
当前共55个项目more
×
寻找源码
源码描述
联系方式
提交