Kafka

Kafka分布式事件流平台,现为Apache开源项目。它以高吞吐、低延迟著称,每秒可处理数百万条消息,并支持数据持久化与多副本容错 。其核心架构基于主题(Topic)和分区(Partition),通过生产者(Producer)和消费者(Consumer)实现发布订阅模式,广泛应用于实时日志收集、消息队列、用户行为跟踪和流处理等大数据场景。
1.支持多数据源(MySQL/Redis/对象存储)到数据仓库的实时/离线同步,兼容全量、增量、CDC等多种同步模式;2.提供可视化任务配置、监控告警、失败重试与自动灾备能力;3.内置流量削峰、限速保护与数据校验机制,保障每日PB级数据流的高效、稳定传输;4.支持同步任务的资源隔离与弹性扩缩容,降低
70Java开发工具
系统聚焦配电网全生命周期智能化管理,核心功能包含:配电设备档案管理、线路台区信息管理、实时运行状态监测、用电负荷动态监控、智能隐患排查、移动端现场巡检打卡、故障上报、智能派单调度、抢修流程闭环管理、运维任务管理、电力数据统计报表、可视化大屏监控、自动台账生成、多级权限管理、操作日志审计等。支持PC端
300Java工业互联网
全局库存中心(GIC):多渠道库存一盘货管理,支持实物库存、预售库存、冻结库存的实时同步与统一水位线预警。智能订单路由引擎(OMS):基于业务规则(成本、距离、时效、库存量)自动对全渠道海量订单进行拆单、合单与寻源分发。供应商与履约风控看板:结合历史数据与外部API,对供应商交期延迟、物流停滞等异常
571Java物流仓储
一、游戏项目,视频直播系统技术点:java,SpringBoot、SpringMVC、SpringCloud,Mybatis、netty,mysql、maven,nginx,redis,protobuf,Linux,shell,docker,RabbitMQ,Vue1、游戏、直播系统后端架构,代码优
500Java游戏
1、功能模块:舆情抓取、样本资源管理、权限管理、机审、人审、数据分析、审核任务管理、机审评测等2、内部有运营管理平台,维护大量数据样本,通过机审->人工复审打标->badcase回补训练来完善审核的准确率。对外提供机审和人审两种审核API。
430Kafka企业服务
1,使用了RBAC系统权限,oauth2.0,第三方集成登录。2,使用了DDD设计。使用了CI/CD集成部署流程3,使用了消息中间件,异步锁等解决分布式,提高系统的健壮性。
370Java企业服务
1、项目包含模块:大数据计算模块,爬虫标准化模块,API模块,管理系统模块2、项目功能:(1)大数据计算模块:根据用户的观影数据,及该影视作品的标签,计算出用户的喜好,并打上标签。根据不同媒资的标签,计算出相似内容用于相似推荐。(2)爬虫标准化模块:根据局方提供的媒资基础信息,去爬取网络,完善其各项
410Java企业服务
1.车辆数据实时接入:支持百万级车辆实时数据上报、采集、校验与清洗。2.大数据存储与计算:海量历史数据存储,日增量3–5T,支持高并发查询。3.Web管理平台:完整后台管理、车辆监控、数据查询、报表统计、权限管理。4.实时监控大屏:车辆状态、运行指标、异常告警可视化展示。5.AI智能分析:接入LLM
590Java企业服务
1.基于DockerCompose,一键部署包含Kafka、Flink、Paimon的完整测试集群2.实现实时数据从Kafka接入,通过FlinkSQL进行清洗转换,并实时写入Paimon数据湖3.验证Paimon的流批一体读写能力,支持分钟级延迟的实时查询4.编写了详细的部署文档和验证脚本
910Java企业服务
1、策略下发与执行支持服务端策略下发到客户端客户端解析并执行本地策略支持30+策略模块独立编译+热更新插件化设计(策略解耦)动态扩展能力强2、多用户隔离机制每个登录用户启动独立Agent基于sessionBus实现用户级策略隔离多用户同时登录互不影响权限隔离(root/user)3、跨进程通信与系统
690C++企业服务
移动反诈功能主要涵盖智能预警、家人守护、保险补偿与技术反制四大核心维度,具体功能分点介绍如下:智能识别与预警:基于AI、大数据及大模型技术,系统能实时监测并识别诈骗电话和短信。当用户接到疑似诈骗电话时,会通过霸屏提醒、语音警示或闪信等方式进行强干预预警,提醒用户注意防范。亲情联防与远程守护:针对老人
740Java企业服务
埋点分析系统产品系统
1、前端埋点上报(包含移动端、web端、后端)2、用户行为埋点数据采集、处理(OneId)、存储3、埋点数据分析查询,包含用户留存分析、用户路径分析、漏斗分析等4、异常数据检测及告警
790Java企业服务
项目实现了“大厅-房间-对局-聊天-通知-会话治理”全链路功能。核心功能包括:1)账号认证与会话治理:基于Keycloak+JWT实现登录鉴权、单设备在线、踢线与会话状态同步;2)实时对局:支持五子棋PVP/PVE,具备建房、入房、准备、开始、落子、认输、重开等流程;3)实时通信:基于WebSock
1590Java企业服务
1.HTTP/HTTPS流量解析与转发对请求头、请求体、URL、参数进行全量解析,实现流量透明代理与转发。2.Web攻击防护支持SQL注入、XSS、命令注入、路径穿越等常见Web漏洞攻击规则拦截。3.访问控制策略支持IP黑白名单、User-Agent过滤、Referer校验、请求频率限流(CC防护)
1110C企业服务
负责交通银行531对公信贷全流程项目的后端开发,主导对公授信审批、放款流程、受托支付、普惠金融及票据业务等核心模块。采用SpringCloud微服务架构,基于DB2数据库,通过Redis缓存与Kafka消息队列实现高并发处理,支撑日均数万笔对公信贷业务。实现了对公客户信息管理、授信额度管控、放款审批
1100Java金融
数据中台项目产品系统
1、设计多源数据整合方案,搭建标准化数据资源池,支撑9万+服务企业数据统一管理;2、主导数据模型全链路开发(ODS/DWD/DWS/ADS分层),设计场景标签与维度模型,优化查询性能,保障模型合理高效;3、参与集团数据治理体系搭建,负责数据质量校验脚本开发,协助搭建元数据平台实现资产可视化;4、负责
1220Kafka项目任务
大禹是网络安全领域高性能大数据安全分析中台:1、对设备接入与资产管理;2、安全能力内置:漏洞检测、情报关联;3、可以对数据接入与治理,例如:日志、流量、漏洞、威胁情报等数据类型;4、事件管理与处置:告警归并、溯源分析、工单联动、自动化响应,缩短安全事件处置时间,降低误报率
1840Java企业服务
可视化监控产品系统
围绕可观测能力建设,打造三大核心监控功能:一是客户维度资源总览,聚合下属主机CPU、内存等资源趋势与告警,实现资源消耗和异常事件一屏总览;二是主机维度精细监控,展示核心指标时序变化,支撑故障定位、性能瓶颈识别与SLA达标分析;三是存储可视化监控,呈现存储容量、性能指标及硬件健康状态,实现存储资源透明
1390Shell企业服务
1.开始创建:创建agent,开始机器人配置。agent可以对应理解为租户的概念,每个agent下的数据和管理是独立使用的。2.语义语料填充:创建实体、意图、问答、闲聊等语料。3.基础资源建设:设置必须的基础资源内容。4.会话流程配置:配置会话流程以实现多轮对话效果。5.BOT装配调试:将配置的语料
1610Java人工智能
时悦上家产品系统
时悦上家是专门针对女性产后康复和身体健康管理提供上门到家服务的平台,为女性提供24H小时的呵护。主要分为用户端,调理师端,平台端,终端分为小程序,安卓,IOS。调理师可以灵活的设置自己的接单状态和接单时间,用户可以在平台选择项目,选择调理师和时间后进行一键下单,只有调理师开启接单状态和接单时间,用户
1530Java企业服务
当前共27个项目more
×
寻找源码
源码描述
联系方式
提交