背景
- 我是Flink的新手，来自Apache Storm背景
- 正在开发无损gRPC接收器
Crux
- 将根据gRPC端点返回的错误代码进行有限次数的重试
- 之后，数据将被刷新到Kafka队列进行离线处理
- 重试的决定将基于返回的错误代码
问题
是否可以链接另一个接收器，以便在下游也可以对任何自定义处理进行响应(成功或错误(？
答案根据Dominik Wosiński 的评论
通常情况下，这是不可能的，您必须解决这一问题，要么在单个接收器中提供这两种功能，要么使用一些现有功能(如AsyncIO(写入gRPC，然后将故障接收到kafka，但如果您需要任何强有力的保证，这可能会更困难。