fix: adds WorkerCount property to MessageConsumer

Farfetch · Oct 6, 2020 · 9c6f851 · 9c6f851
1 parent 3cb9c4c
commit 9c6f851
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/KafkaFlow/Consumers/MessageConsumer.cs b/src/KafkaFlow/Consumers/MessageConsumer.cs
@@ -33,6 +33,8 @@ public MessageConsumer(
 
         public string GroupId => this.configuration.GroupId;
 
+        public int WorkerCount => this.configuration.WorkerCount;
+
         public async Task OverrideOffsetsAndRestartAsync(IReadOnlyCollection<TopicPartitionOffset> offsets)
         {
             if (offsets is null)