File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -242,11 +242,11 @@ private void EnsureConsumer()
242242 . SetPartitionsRevokedHandler (
243243 ( consumer , partitions ) =>
244244 {
245+ _partitionsRevokedHandlers . ForEach ( handler => handler ( _dependencyResolver , consumer , partitions ) ) ;
245246 this . Assignment = new List < TopicPartition > ( ) ;
246247 this . Subscription = new List < string > ( ) ;
247248 _currentPartitionsOffsets . Clear ( ) ;
248249 _flowManager . Stop ( ) ;
249- _partitionsRevokedHandlers . ForEach ( handler => handler ( _dependencyResolver , consumer , partitions ) ) ;
250250 } )
251251 . SetErrorHandler ( ( consumer , error ) => _errorsHandlers . ForEach ( x => x ( consumer , error ) ) )
252252 . SetStatisticsHandler ( ( consumer , statistics ) => _statisticsHandlers . ForEach ( x => x ( consumer , statistics ) ) ) ;
You can’t perform that action at this time.
0 commit comments