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