小贝子编程

在 Apache Flink 中，Kafka 的消息是如何消费的?



我知道每次都会消耗一批数据以减少网络调用，但消耗速率是否仅取决于源运营商，还是对 Sink 的确认也很重要？在这种情况下如何处理突发？

源和接收器松散耦合。如果接收器跟不上，则会导致背压，背压将通过作业图级联，从而阻止源能够比消耗数据更快地向下游写入数据，这将减慢其读取速率(从而匹配接收器(。

了解 Apache Flink 如何处理背压 了解更多信息。

相关内容

  • 没有找到相关文章

最新更新


热门标签：

javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium