我在这里查看KafkaConsumer 源代码。从查看源代码(在java中,我不太熟悉)来看,暂停主题分区似乎将其偏移状态设置为暂停。我试图弄清楚 KafkaConsumer 在后台执行的提取会发生什么,以及暂停主题分区是否会停止 kafka 消费者所做的预取,或者它是否继续预取但不返回该主题的 ConsumerRecords投票分区。
慕沐林林
相关分类