public ValidateOptionsResult Validate()

in src/Epam.Kafka/Options/Validation/ConsumerValidation.cs [9:36]


    public ValidateOptionsResult Validate(string? name, KafkaConsumerOptions options)
    {
        if (options == null)
        {
            throw new ArgumentNullException(nameof(options));
        }

        if (name == null)
        {
            return ValidateOptionsResult.Fail("Unable to create consumer without name");
        }

        if (string.IsNullOrWhiteSpace(options.ConsumerConfig.GroupId))
        {
            return ValidateOptionsResult.Fail("group.id is null or whitespace.");
        }

        try
        {
            options.ConsumerConfig.GetCancellationDelayMaxMs();
        }
        catch (ArgumentException e)
        {
            return ValidateOptionsResult.Fail(e.Message);
        }

        return ValidateOptionsResult.Success;
    }