Flink：流批一体的实时计算引擎

Flink 以事件时间和状态为核心，天然支持流处理与批处理；实时数仓中承担 CDC 入湖、实时 ETL 与实时指标计算。

提交实时作业

flink run -d -p 8 \
  -c com.demo.TradeOrderJob \
  /opt/jobs/trade-order-job.jar \
  --kafka.bootstrap broker:9092 \
  --checkpoint.interval 60000

实时作业的并行度与 Kafka 分区数对齐，避免部分分区消费成为瓶颈。

‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌