Skip to content

Commit e121a5b

Browse files
massadajoelfoliveira
authored andcommitted
fix: stop flow manager after calling revoke handlers
1 parent 433f337 commit e121a5b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/KafkaFlow/Consumers/Consumer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff 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)));

0 commit comments

Comments
 (0)