Ошибка при создании consumer kafka?

Question

[Алекс Федоров]

Привет! Помогите пожалуйста, что не так. Написал консюмера для кафки, правильно ввожу данные , но выходит ошибка

%4|1654290146.137|BROKER|rdkafka#consumer-1| [thrd:app]: Broker name "https://broker2.82.148вв0.sslip.io:3вв01" parse error: unsupported protocol "HTTPS"
%3|1654290146.138|ERROR|rdkafka#consumer-1| [thrd:app]: No brokers configured

Айпишник специально неправильно написал.

using Confluent.Kafka;

class Program
{
    public static void Main(string[] args)
    {
        var conf = new ConsumerConfig
        {
            BootstrapServers = "https://broker2.82.148фslip.iфыссo:32вфыв1",
            GroupId = "gфывtest",
            AutoOffsetReset = AutoOffsetReset.Earliest,
            SecurityProtocol = SecurityProtocol.Ssl,
            EnableSslCertificateVerification = false            
        };

        using (var c = new ConsumerBuilder<Ignore, string>(conf).Build())
        {
            c.Subscribe("gateway-log-topic");

            CancellationTokenSource cts = new CancellationTokenSource();
            Console.CancelKeyPress += (_, e) => {
                e.Cancel = true; // prevent the process from terminating.
                cts.Cancel();
            };

            try
            {
                while (true)
                {
                    try
                    {
                        var cr = c.Consume(cts.Token);
                        Console.WriteLine($"Consumed message '{cr.Value}' at: '{cr.TopicPartitionOffset}'.");
                    }
                    catch (ConsumeException e)
                    {
                        Console.WriteLine($"Error occured: {e.Error.Reason}");
                    }
                }
            }
            catch (OperationCanceledException)
            {
                c.Close();
            }
        }
    }
}

Помогите, более опытные товарищи, что я делаю не так ??
вроде просто копипастнул с семпла. или проблема в брокере кафки ?

Comments

[Владислав]

У тебя точно включен на брокере https прокотол?
Если ты включаешь SecurityProtocol = SecurityProtocol.Ssl, то должен еще указать сертификаты для работы с брокером
Не хочешь заморачиваться с сертификатами, то переключи брокера с SSL на Plaintext и всё

И если я правильно помню, то не нужно в адресе указывать протокол. Там просто ip:port должен быть