我们构建了一个自定义Kafka Connect接收器，该接收器又调用远程REST API . 如何将背压传播到Kafka Connect基础架构，因此在远程系统比内部消费者向put（）传递消息的速度慢的情况下，调用put（）的频率较低？ Kafka连接文档说我们不应该在put（）中阻塞，而是在flush（）中阻塞 . 但是put（）中没有阻塞意味着我们必须缓冲数据，如果put（）被调用的频率高于flush（），那么肯定会在某些时候导致OOM异常 . 我已经看到允许kafka使用者在循环（）中调用pause（）或阻塞 . 是否有可能在 Kafka 连接接收器中利用它？