in src/Epam.Kafka.PubSub/Subscription/SubscriptionBackgroundService.cs [81:97]
protected override TimeSpan? GetBatchFinishedTimeout(SubscriptionBatchResult subscriptionBatchResult)
{
TimeSpan? timeout = null;
if (subscriptionBatchResult == SubscriptionBatchResult.Paused && this.Options.BatchPausedTimeout.Ticks > 0)
{
timeout = this.Options.BatchPausedTimeout;
}
if (subscriptionBatchResult == SubscriptionBatchResult.NotAssigned &&
this.Options.BatchNotAssignedTimeout.Ticks > 0)
{
timeout = this.Options.BatchNotAssignedTimeout;
}
return timeout;
}