Kafka

Kafka分布式事件流平台,现为Apache开源项目。它以高吞吐、低延迟著称,每秒可处理数百万条消息,并支持数据持久化与多副本容错 。其核心架构基于主题(Topic)和分区(Partition),通过生产者(Producer)和消费者(Consumer)实现发布订阅模式,广泛应用于实时日志收集、消息队列、用户行为跟踪和流处理等大数据场景。
1、项目包含模块:大数据计算模块,爬虫标准化模块,API模块,管理系统模块2、项目功能:(1)大数据计算模块:根据用户的观影数据,及该影视作品的标签,计算出用户的喜好,并打上标签。根据不同媒资的标签,计算出相似内容用于相似推荐。(2)爬虫标准化模块:根据局方提供的媒资基础信息,去爬取网络,完善其各项
190Java企业服务
1.车辆数据实时接入:支持百万级车辆实时数据上报、采集、校验与清洗。2.大数据存储与计算:海量历史数据存储,日增量3–5T,支持高并发查询。3.Web管理平台:完整后台管理、车辆监控、数据查询、报表统计、权限管理。4.实时监控大屏:车辆状态、运行指标、异常告警可视化展示。5.AI智能分析:接入LLM
320Java企业服务
1、核心痛点解决:官方spring-kafka仅支持单一Kafka集群配置,本项目完美解决项目中需要对接单个或多个Kafka集群的场景需求。2、三大核心能力:a)多集群灵活配置支持单一集群或多集群同时配置支持多种安全策略(SASL认证、SSL证书认证、宽松认证等)可动态启用/禁用特定集群配置支持主配
350Java开发工具
1.基于DockerCompose,一键部署包含Kafka、Flink、Paimon的完整测试集群2.实现实时数据从Kafka接入,通过FlinkSQL进行清洗转换,并实时写入Paimon数据湖3.验证Paimon的流批一体读写能力,支持分钟级延迟的实时查询4.编写了详细的部署文档和验证脚本
550Java企业服务
本系统提供完整的充电桩管理解决方案,核心功能包括:设备注册与管理、用户扫码充电、订单推送与结算。支持实时监控设备状态、远程启停充电、故障告警通知,并提供用户账户管理、充电记录查询、多种支付方式接入及数据统计分析,助力运营方高效管理充电网络。
400Java工业互联网
1、策略下发与执行支持服务端策略下发到客户端客户端解析并执行本地策略支持30+策略模块独立编译+热更新插件化设计(策略解耦)动态扩展能力强2、多用户隔离机制每个登录用户启动独立Agent基于sessionBus实现用户级策略隔离多用户同时登录互不影响权限隔离(root/user)3、跨进程通信与系统
480C++企业服务
移动反诈功能主要涵盖智能预警、家人守护、保险补偿与技术反制四大核心维度,具体功能分点介绍如下:智能识别与预警:基于AI、大数据及大模型技术,系统能实时监测并识别诈骗电话和短信。当用户接到疑似诈骗电话时,会通过霸屏提醒、语音警示或闪信等方式进行强干预预警,提醒用户注意防范。亲情联防与远程守护:针对老人
510Java企业服务
埋点分析系统产品系统
1、前端埋点上报(包含移动端、web端、后端)2、用户行为埋点数据采集、处理(OneId)、存储3、埋点数据分析查询,包含用户留存分析、用户路径分析、漏斗分析等4、异常数据检测及告警
600Java企业服务
项目实现了“大厅-房间-对局-聊天-通知-会话治理”全链路功能。核心功能包括:1)账号认证与会话治理:基于Keycloak+JWT实现登录鉴权、单设备在线、踢线与会话状态同步;2)实时对局:支持五子棋PVP/PVE,具备建房、入房、准备、开始、落子、认输、重开等流程;3)实时通信:基于WebSock
1100Java企业服务
1.HTTP/HTTPS流量解析与转发对请求头、请求体、URL、参数进行全量解析,实现流量透明代理与转发。2.Web攻击防护支持SQL注入、XSS、命令注入、路径穿越等常见Web漏洞攻击规则拦截。3.访问控制策略支持IP黑白名单、User-Agent过滤、Referer校验、请求频率限流(CC防护)
910C企业服务
负责交通银行531对公信贷全流程项目的后端开发,主导对公授信审批、放款流程、受托支付、普惠金融及票据业务等核心模块。采用SpringCloud微服务架构,基于DB2数据库,通过Redis缓存与Kafka消息队列实现高并发处理,支撑日均数万笔对公信贷业务。实现了对公客户信息管理、授信额度管控、放款审批
890Java金融
数据中台项目产品系统
1、设计多源数据整合方案,搭建标准化数据资源池,支撑9万+服务企业数据统一管理;2、主导数据模型全链路开发(ODS/DWD/DWS/ADS分层),设计场景标签与维度模型,优化查询性能,保障模型合理高效;3、参与集团数据治理体系搭建,负责数据质量校验脚本开发,协助搭建元数据平台实现资产可视化;4、负责
1010Kafka项目任务
大禹是网络安全领域高性能大数据安全分析中台:1、对设备接入与资产管理;2、安全能力内置:漏洞检测、情报关联;3、可以对数据接入与治理,例如:日志、流量、漏洞、威胁情报等数据类型;4、事件管理与处置:告警归并、溯源分析、工单联动、自动化响应,缩短安全事件处置时间,降低误报率
1540Java企业服务
可视化监控产品系统
围绕可观测能力建设,打造三大核心监控功能:一是客户维度资源总览,聚合下属主机CPU、内存等资源趋势与告警,实现资源消耗和异常事件一屏总览;二是主机维度精细监控,展示核心指标时序变化,支撑故障定位、性能瓶颈识别与SLA达标分析;三是存储可视化监控,呈现存储容量、性能指标及硬件健康状态,实现存储资源透明
1060Shell企业服务
1.开始创建:创建agent,开始机器人配置。agent可以对应理解为租户的概念,每个agent下的数据和管理是独立使用的。2.语义语料填充:创建实体、意图、问答、闲聊等语料。3.基础资源建设:设置必须的基础资源内容。4.会话流程配置:配置会话流程以实现多轮对话效果。5.BOT装配调试:将配置的语料
1280Java人工智能
时悦上家产品系统
时悦上家是专门针对女性产后康复和身体健康管理提供上门到家服务的平台,为女性提供24H小时的呵护。主要分为用户端,调理师端,平台端,终端分为小程序,安卓,IOS。调理师可以灵活的设置自己的接单状态和接单时间,用户可以在平台选择项目,选择调理师和时间后进行一键下单,只有调理师开启接单状态和接单时间,用户
1320Java企业服务
ERP产品系统
为了方便公司的资产管理,研发系统线上化管理公司资产与每个员工业绩,减轻各部门人员线下的压力,公司租赁合同管理,客户信息管理,财务对账管理,客服服务通知管理,售后工单管理,库房进销存管理,设备分布管理等
1400PHP企业服务
1.Kinmouse图形建模模块(exp-kinmouse)模块职责:负责可视化数据建模功能的设计与实现技术实现:基于SpringBoot构建RESTfuIAPI服务实现图形化建模工具的后端逻辑支持拖拽式建模和模型配置管理集成函数库管理和脚本执行引擎核心功能:数据模型图形化设计界面支持模型节点和连接
930Java企业服务
1、数据源接入模块:承担数据的传输与清洗的角色。2、数仓模块:数据建模,通过将原始数据进行多层处理变换,使最新数据拆分到维度层中存储,历史数据抽象到其余层级进行加工,最终达到分析统计以及展示目的。3、规则组装模块:生成存储标签系统的规则语句。4、标签模块:根据标签规则库中定义的标签规则对人事数据进行
1830Java工业互联网
按业务功能主要分为商品,会员,营销,企微,订单,财务,数据等大模块。商品模块承载商户线上和线下商户和门店商品基础数据;会员承载商户线上和线上会员数字资产数据;企微模块是对接企业微信进行客户群体管理;订单模块承载商户和门店线上和线下订单数据的扭转;财务模块主要是统计和汇总商户线上和线下财务订单数据,便
2710Java企业服务
当前共23个项目more
×
寻找源码
源码描述
联系方式
提交