Kafka

Kafka分布式事件流平台,现为Apache开源项目。它以高吞吐、低延迟著称,每秒可处理数百万条消息,并支持数据持久化与多副本容错 。其核心架构基于主题(Topic)和分区(Partition),通过生产者(Producer)和消费者(Consumer)实现发布订阅模式,广泛应用于实时日志收集、消息队列、用户行为跟踪和流处理等大数据场景。
*三维地图展示*实时监测数据展示*企业运行状态监测*视频监控接入*告警中心*数据统计分析*综合态势分析*大屏驾驶舱展示*多业务系统数据融合
110Java政务
*OBD在线监测数据接入*非道路移动机械监管*企业门禁车辆进出管理*企业车辆备案管理*排放异常预警*GIS地图展示*企业统计分析*数据驾驶舱*与国家、省、市环保监管平台数据交换*多维度数据查询及报表导出
120Java企业服务
平台包含员工入职、转正、调岗、离职全生命周期管理模块,以及培训管理、薪酬管理、数字化档案管理、智能客服等核心功能。支持PC端和移动端跨终端访问,提供多租户权限管理,满足不同分公司的个性化需求。集成BI数据分析看板,为集团人力资源决策提供数据支撑。
340Java企业服务
IAMS是一套完整的保单台账管理系统,集合以下核心功能:1.**智能保单解析**:AI驱动的PDF自动识别,准确率达90%+2.**全生命周期管理**:保单录入、编辑、审核、统计全流程覆盖3.**分级权限管控**:灵活的角色权限体系,支持多租户模式4.**多维数据分析**:财务报表、大屏可视化、趋势
340Java金融
包括贷款抵押审批流程、收费减免管理流程、垫资、返费、退费等贷前管理,贷中的还款、催款、提前结清、委派申请等相关流程以及贷后的跟踪和服务包括法务起诉、委托申请、外访申请、资产处置等相关流程的全生命周期的贷款管理流程。
310Java金融
特征系统产品系统
本特征系统作为统一特征中台,集成实时、准实时、离线全类型特征生命周期管控能力。支持实时特征数据上报、写入存储与在线高并发查询,依托Flink完成流式数据加工;基于Doris实现准实时特征高效存取,借助Hive承载海量离线特征计算、入库与检索。平台统一管理数据源、数据元、特征元数据,搭配QLExpre
420Java企业服务
1.数据采集模块:支持多源数据同步,对接日志、数据库、接口等多渠道数据,实现亿级日志数据的稳定接入;2.数据处理模块:对采集数据进行清洗、标准化、过滤与聚合,将数据同步延迟控制在秒级,数据一致性校验通过率达99.9%;3.审计分析模块:提供规则引擎与行为分析,自动识别并拦截业务异常与违规操作,生成审
450Java企业服务
1、防汛防台风综合指挥系统主要归集各类预警数据并进行数据分析;2、归集了气象、雨情、水情监测预警数据并进行分析,生成气象、洪水预报以及模拟预演,实现了对汛情动态及台风路径等关键信息的精准监测与分析。3、相关人员可以从分析研判中查看淹没过程分析、淹没损失评估以及历史灾害对比情况。4、应急调度模块包括视
550Java工业互联网
某领域QB数据资源体系建设系统为涉密重点工程,搭建全生命周期数据管理体系,形成“采集—清洗—治理—应用”一体化闭环,包含五大核心功能模块。数据采集汇聚模块,支持多格式、多方式数据接入,兼具数据监控、采报、引接与管理能力,适配海量异构数据汇聚更新。智能数据治理模块,依托整编工作台、治理及模型引擎、数据
520Java项目任务
多源时空分析西安市局综合性数据分析平台,贯通数据采集、治理、分析、应用全流程。依托WiFi信令海量数据实时运算处理,完成数据规整与深度研判,可精准甄别重点目标、开展动态管控。共有七大功能模块:案件中心统筹案件相关数据,消息中心推送各类动态讯息,查询中心支持多维度信息检索,数据监测中心实时把控数据态势
380Java企业服务
1.支持多数据源(MySQL/Redis/对象存储)到数据仓库的实时/离线同步,兼容全量、增量、CDC等多种同步模式;2.提供可视化任务配置、监控告警、失败重试与自动灾备能力;3.内置流量削峰、限速保护与数据校验机制,保障每日PB级数据流的高效、稳定传输;4.支持同步任务的资源隔离与弹性扩缩容,降低
380Java开发工具
系统聚焦配电网全生命周期智能化管理,核心功能包含:配电设备档案管理、线路台区信息管理、实时运行状态监测、用电负荷动态监控、智能隐患排查、移动端现场巡检打卡、故障上报、智能派单调度、抢修流程闭环管理、运维任务管理、电力数据统计报表、可视化大屏监控、自动台账生成、多级权限管理、操作日志审计等。支持PC端
690Java工业互联网
全局库存中心(GIC):多渠道库存一盘货管理,支持实物库存、预售库存、冻结库存的实时同步与统一水位线预警。智能订单路由引擎(OMS):基于业务规则(成本、距离、时效、库存量)自动对全渠道海量订单进行拆单、合单与寻源分发。供应商与履约风控看板:结合历史数据与外部API,对供应商交期延迟、物流停滞等异常
1081Java物流仓储
一、游戏项目,视频直播系统技术点:java,SpringBoot、SpringMVC、SpringCloud,Mybatis、netty,mysql、maven,nginx,redis,protobuf,Linux,shell,docker,RabbitMQ,Vue1、游戏、直播系统后端架构,代码优
770Java游戏
1、功能模块:舆情抓取、样本资源管理、权限管理、机审、人审、数据分析、审核任务管理、机审评测等2、内部有运营管理平台,维护大量数据样本,通过机审->人工复审打标->badcase回补训练来完善审核的准确率。对外提供机审和人审两种审核API。
730Kafka企业服务
1,使用了RBAC系统权限,oauth2.0,第三方集成登录。2,使用了DDD设计。使用了CI/CD集成部署流程3,使用了消息中间件,异步锁等解决分布式,提高系统的健壮性。
480Java企业服务
1、项目包含模块:大数据计算模块,爬虫标准化模块,API模块,管理系统模块2、项目功能:(1)大数据计算模块:根据用户的观影数据,及该影视作品的标签,计算出用户的喜好,并打上标签。根据不同媒资的标签,计算出相似内容用于相似推荐。(2)爬虫标准化模块:根据局方提供的媒资基础信息,去爬取网络,完善其各项
580Java企业服务
1.车辆数据实时接入:支持百万级车辆实时数据上报、采集、校验与清洗。2.大数据存储与计算:海量历史数据存储,日增量3–5T,支持高并发查询。3.Web管理平台:完整后台管理、车辆监控、数据查询、报表统计、权限管理。4.实时监控大屏:车辆状态、运行指标、异常告警可视化展示。5.AI智能分析:接入LLM
710Java企业服务
1、核心痛点解决:官方spring-kafka仅支持单一Kafka集群配置,本项目完美解决项目中需要对接单个或多个Kafka集群的场景需求。2、三大核心能力:a)多集群灵活配置支持单一集群或多集群同时配置支持多种安全策略(SASL认证、SSL证书认证、宽松认证等)可动态启用/禁用特定集群配置支持主配
690Java开发工具
1.基于DockerCompose,一键部署包含Kafka、Flink、Paimon的完整测试集群2.实现实时数据从Kafka接入,通过FlinkSQL进行清洗转换,并实时写入Paimon数据湖3.验证Paimon的流批一体读写能力,支持分钟级延迟的实时查询4.编写了详细的部署文档和验证脚本
1270Java企业服务
当前共39个项目more
×
寻找源码
源码描述
联系方式
提交