removeExpiredProducers(currentTimeMs: Long): Unit
ProducerStateManager
ProducerStateManager
is…FIXME
removeExpiredProducers
Method
removeExpiredProducers
…FIXME
Note
|
removeExpiredProducers is used when…FIXME
|
takeSnapshot
Method
takeSnapshot(): Unit
takeSnapshot
…FIXME
Note
|
takeSnapshot is used when Log is requested to recoverSegment, rebuildProducerState, close, and roll.
|