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.
|