我在這里查看KafkaConsumer 源代碼。從查看源代碼(在java中,我不太熟悉)來(lái)看,暫停主題分區(qū)似乎將其偏移狀態(tài)設(shè)置為暫停。我試圖弄清楚 KafkaConsumer 在后臺(tái)執(zhí)行的提取會(huì)發(fā)生什么,以及暫停主題分區(qū)是否會(huì)停止 kafka 消費(fèi)者所做的預(yù)取,或者它是否繼續(xù)預(yù)取但不返回該主題的 ConsumerRecords投票分區(qū)。
KafkaConsumer 是否仍會(huì)繼續(xù)在后臺(tái)獲取處于暫停狀態(tài)的主題分區(qū)?
慕桂英3389331
2021-12-01 15:35:27