Kafka

首页 标签 Kafka
# Kafka #
关注
10054内容
|
2天前
| |
基于Kerberos认证的大数据权限解决方案
Kerberos是由麻省理工(MIT)开发,对三方进行验证鉴权的服务安全管理系统。
|
3天前
| |
Flink Time 之间断性 WaterMark 原理深度剖析:从触发机制到内部实现与适用场景
本文深入解析Flink断点式Watermark(Punctuated Watermark):它在每个事件到达时通过`onEvent`动态判断是否触发,实现事件级精确水位推进,适用于事务边界、心跳、批次结束等标记事件场景;虽精度高但依赖标记事件,需搭配周期性Watermark兜底防停滞。
|
9天前
|
迪康终端行为审计的数据链路:从内核事件到秒级溯源查询
终端审计数据链路设计实战指南:直击千台终端日均亿级事件的采集、传输、存储与秒级查询难题。聚焦双时间戳、硬件指纹、边缘聚合、列式存储(ClickHouse)、冷热分层等关键设计,破解写入洪流与精准查询的矛盾,避免80%项目因链路崩塌而烂尾。(239字)
|
14天前
| |
来自: 云原生
云栖剧透丨AI 应用进入生产,开始拼「实时数据智能」
9 月 22 日下午,欢迎来到杭州国际博览中心一期四楼 404 厅,与我们一起讨论实时数据智能如何支撑 AI 应用真正进入生产。
|
15天前
|
Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题
本文详解 Apache Flink CDC 从 Savepoint/Checkpoint 恢复失败的四大主因:Schema 不兼容、版本升级导致状态不兼容、连接器配置差异及检查点损坏,并提供系统化排查步骤与预防最佳实践,助力稳定数据同步。(239字)
数据集成到底在集成什么?数据库、API、文件、消息队列一次讲清
数据集成远不止“搬数据”:它本质是构建企业级数据供应链,统一连接、变化识别、结构转换、异常处理与运行调度。需按数据特征(来源、量级、频次、时效)选择数据库(CDC)、API(契约)、文件(协议)或消息队列(事件),实现可信、可持续、可追踪的数据流动。(239字)
|
1月前
|
云呼叫中心部署阿里云,高可用架构落地经验分享
本文围绕云呼叫中心在阿里云上的高可用架构落地展开,系统分析多可用区部署、SLB 负载均衡、ACK 弹性伸缩、RDS 高可用、Redis 集群、Kafka 跨区副本、VPC 网络规划、监控告警与故障切换等关键技术点。文章给出三层高可用架构、核心配置参数、Terraform 可部署模板、脱敏实测数据、容灾切换时序、踩坑记录与成本对比。核心结论:云呼叫中心建议采用“多可用区 + SLB + 无状态计算 + 主备数据”架构,核心组件跨可用区部署,端到端可用性可达 99.95% 以上,RDS 主备切换 ≤30s,Redis 故障转移 ≤15s,Kafka 副本切换 ≤10s。
Kafka 接入 AI 的三条路线:MCP 提案、会话记忆与实时上下文
Kafka 接入 AI 的三条路线:第一方 MCP Server 提案、Streams 会话记忆、Flink SQL 实时上下文,附选型对比与权限清单
|
1月前
| |
来自: 云原生
实时上下文:当模型能力趋于充裕,AI 生产化的瓶颈正移向实时数据链路
8 月 28 日,由极客传媒 InfoQ、阿里云和 IBM 联合举办的「AI 实时数据沙龙 · 上海站」上,三位来自阿里云和 IBM 的一线工程师围绕这条链路做了分享:一场讲数据流平台面向 AI 的整体演进,另两场分别落到阿里云消息队列 Confluent 版(ApsaraMQ for Confluent)和云消息队列 Kafka 版(ApsaraMQ for Kafka)两款产品的演进与实践。三场分享层层承接,给出的判断是一致的:当模型能力趋于充裕,AI 生产化的瓶颈正移向实时数据链路。
免费试用