Multiple Mqtt brokers in different ports ?

[felixalguzman]

Is it possible to connect to different mqtt brokers running in different ports ?

[BEagle1984]

Yes, you can definitely connect to multiple MQTT and/or Kafka brokers from the same application, having completely different settings for each client.

The client configuration can be completely set or overridden inside the AddInbound configuration action, using the Configure method.

public class MyEndpointsConfigurator : IEndpointsConfigurator
{
    public void Configure(IEndpointsConfigurationBuilder builder) =>
        builder
            .AddMqttEndpoints(endpoints => endpoints
                .AddInbound(endpoint => endpoint
                    .Configure(config => config.WithClientId("client1").ConnectViaTcp("broker1", 1111))
                    .ConsumeFrom("some/topic"))
                .AddInbound(endpoint => endpoint
                    .Configure(config => config.WithClientId("client1").ConnectViaTcp("broker2", 2222))
                    .ConsumeFrom("other/topic")));
}

[felixalguzman]

Great, thanks!