关于服务
翻译我在 Apache Flink 上构建生产级流处理管道，将事件流转化为即时且可靠的分析。如果数据现在以批次到达，而洞察与现实之间有数小时的延迟，我会缩小这个差距。我围绕事件时间和水印设计作业，因此迟到和乱序的事件会被正确处理，而不是默默破坏指标。状态后端、检查点和保存点我会调优以实现高吞吐量和快速故障恢复。
首要任务是在负载下的正确性。我实现端到端的精确一次语义：在支持的地方使用事务性接收器，在其他地方使用幂等写入，因此故障转移不会导致双重收费，也不会丢失订单。我在多个源之间构建流连接，用参考数据丰富事件，并通过 Flink CEP 及时捕捉欺诈链、漏斗掉落和 SLA 违规。您将获得干净的代码、经过测试的部署和团队文档；我与 Kafka、Kinesis、Pulsar、JDBC 和对象存储合作。
— 事件时间和窗口聚合
— 精确一次、检查点和保存点
— 连接、丰富和 Flink CEP 模式
— 实时分析、警报和监控
首要任务是在负载下的正确性。我实现端到端的精确一次语义：在支持的地方使用事务性接收器，在其他地方使用幂等写入，因此故障转移不会导致双重收费，也不会丢失订单。我在多个源之间构建流连接，用参考数据丰富事件，并通过 Flink CEP 及时捕捉欺诈链、漏斗掉落和 SLA 违规。您将获得干净的代码、经过测试的部署和团队文档；我与 Kafka、Kinesis、Pulsar、JDBC 和对象存储合作。
— 事件时间和窗口聚合
— 精确一次、检查点和保存点
— 连接、丰富和 Flink CEP 模式
— 实时分析、警报和监控
