gpt4 book ai didi

java - KafkaConsumer 是否仍会继续在后台获取处于暂停状态的主题分区?

转载 作者:行者123 更新时间:2023-12-02 01:51:31 25 4
gpt4 key购买 nike

我正在查看KafkaConsumer源代码here 。从查看源代码(在java中,我不太熟悉)来看,暂停一个topicpartition似乎将其偏移状态设置为暂停。我试图弄清楚 KafkaConsumer 在后台执行的获取操作会发生什么情况,以及暂停主题分区是否会停止 kafka 消费者执行的预取操作,或者是否继续预取但不返回该主题的 ConsumerRecords轮询分区。

最佳答案

两者都有。暂停分区会停止该分区的预取,并在轮询时返回空。

关于java - KafkaConsumer 是否仍会继续在后台获取处于暂停状态的主题分区?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52922424/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com