VIP10
本课程属于：037-Kafka与Flink金融实时数据工程 智能金融与金融工程 · 共 10 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka金融行情高吞吐管道实战

共计 30 章节
可可资料掘金营 · 点击在线试看
01
课程导入
目标=金融行情数据特征 · 高吞吐管道挑战 · Kafka核心价值与课程学习路线
课程导入目标=金融行情数…
02
Kafka基础概念
目标=Topic · Partition · Broker
Kafka基础概念
03
金融行情数据模型
目标=Level-1/Level-2… · 逐笔委托 · 逐笔成交
金融行情数据模型Level-1/Leve…
04
Kafka集群规划
目标=Broker数量 · 磁盘选型 · 网络带宽
Kafka集群规划
05
Topic设计实战
目标=分区数估算 · 副本因子 · 数据保留策略
Topic设计实战
06
生产者核心机制
目标=分区器 · 拦截器 · 序列化器
生产者核心机制目标=分区器
07
生产者性能调优
目标=acks · linger.ms · batch.size
生产者性能调优acks
08
消费者核心机制
目标=拉取模型 · 位移提交 · 再均衡
消费者核心机制目标=拉取模型
09
消费者性能调优
目标=fetch.min.bytes · max.poll.records · 分区分配策略与并行消费
消费者性能调优fetch.min.by…
10
高吞吐写入实战
目标=行情接入网关设计 · 批量发送 · 异步回调与背压处理
高吞吐写入实战目标=行情接入网…
11
高吞吐读取实战
目标=多消费者组并行消费 · 位移管理 · 重复消费与消息去重
高吞吐读取实战目标=多消费者组…
12
数据可靠性保障
目标=副本同步 · ISR · min.insync.replica…
数据可靠性保障目标=副本同步
13
Exactly-Once语义
目标=幂等生产者 · 事务 · 消费-处理-生产事务链路与金融场景取…
Exactly-Once语义
14
Kafka Streams入门
目标=流处理拓扑 · KTable · KStream
KafkaStreams
15
行情实时计算实战
目标=VWAP · 成交量统计 · 涨跌幅计算与窗口聚合
行情实时计算实战VWAP
16
Kafka Connect应用
目标=行情数据源接入 · HDFS/S3/ClickHouse…
KafkaConnect
17
Schema管理
目标=Avro · Protobuf · Schema Registry与行情…
Schema管理
18
监控与告警
目标=JMX指标 · Prometheus · Grafana
监控告警
19
性能压测实战
目标=行情回放工具 · 吞吐量测试 · 延迟测量与瓶颈定位
性能压测实战目标=行情回放工…
20
故障处理实战
目标=Broker宕机 · 网络分区 · 磁盘写满
故障处理实战Broker
21
安全与权限
目标=SASL · SSL · ACL
安全权限
22
多数据中心方案
目标=MirrorMaker 2 · 集群链接 · 异地容灾与数据一致性
多数据心方案
23
行情回放与历史数据
目标=按时间戳回放 · 时间索引 · 分层存储与冷热数据分离
行情回放历史数据
24
低延迟优化
目标=操作系统调优 · JVM调优 · 零拷贝
低延迟优化目标=操作系统调…
25
综合案例一
目标=股票Level-2行情高吞吐管…
综合案例一Level-2
26
综合案例二
目标=期货行情实时风控管道与异常检测
综合案例二目标=期货行情实…
27
综合案例三
目标=加密货币行情跨交易所聚合与实时…
综合案例三目标=加密货币行…
28
常见问题排查
目标=消息丢失 · 消息重复 · 消费延迟
常见问题排查目标=消息丢失
29
架构演进与选型
目标=Kafka与Pulsar · Redpanda · RocketMQ在金融行情场景的对比
架构演进选型
30
课程总结与进阶
目标=知识体系回顾 · 最佳实践清单 · 持续学习资源与实战项目建议
课程总结进阶