在 Flink 算子中使用多线程如何保证不丢数据？

本人经过分析痛点、同步批量请求优化为异步请求、多线程 Client 模式、Flink 算子内多线程实现以及总结四部分帮助你们理解 Flink 中使用多线程的优化及在 Flink 算子中使用多线程如何保证不丢数据。web 分析痛点 笔者线上有一个 Flink 任务消费 Kafka 数据，将数据转换后，在 Flink 的 Sink 算子内部调用第三方 api 将数据上报到第三方的数据分析平台。这里使用

>>阅读原文<<