链接 Flink 接收器

Question

背景

• 我是 Flink 新手，来自 Apache Storm 背景
• 致力于开发无损 gRPC 接收器

症结

• 有限的编号。重试次数将根据 gRPC 端点返回的错误代码进行
• 之后数据会被刷新到 Kafka Queue 进行离线处理
• 重试的决定将基于返回的错误代码。

问题

是否可以链接另一个接收器，以便响应（成功或错误）也可用于下游的任何自定义处理？

Answer 1

答案是comment by Dominik Wosiński

一般来说这是不可能的，您必须解决这个问题，或者通过在单个接收器中提供这两个功能，或者使用一些现有的功能（如 AsyncIO）写入 gRPC，然后将故障接收到 kafka，但这可能更难如果您需要任何强有力的保证。