Show / Hide Table of Contents

    Class KafkaClientConfigurationBuilder

    Builds the KafkaProducerConfiguration.

    Inheritance
    object
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>
    KafkaClientConfigurationBuilder
    Inherited Members
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslMechanism(SaslMechanism?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithAcks(Acks?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithBootstrapServers(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithMessageMaxBytes(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithMessageCopyMaxBytes(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithReceiveMessageMaxBytes(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithMaxInFlight(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithMetadataRecoveryStrategy(MetadataRecoveryStrategy?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithMetadataRecoveryRebootstrapTriggerMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithTopicMetadataRefreshIntervalMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithMetadataMaxAgeMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithTopicMetadataRefreshFastIntervalMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.EnableSparseTopicMetadataRefresh()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.DisableSparseTopicMetadataRefresh()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithTopicMetadataPropagationMaxMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithTopicBlacklist(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithDebug(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSocketTimeoutMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSocketSendBufferBytes(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSocketReceiveBufferBytes(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.EnableSocketKeepalive()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.DisableSocketKeepalive()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.DisableSocketNagle()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.EnableSocketNagle()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSocketMaxFails(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithBrokerAddressTtl(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithBrokerAddressFamily(BrokerAddressFamily?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSocketConnectionSetupTimeoutMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithConnectionsMaxIdleMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithReconnectBackoffMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithReconnectBackoffMaxMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithStatisticsIntervalMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.EnableApiVersionRequest()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.DisableApiVersionRequest()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithApiVersionRequestTimeoutMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithApiVersionFallbackMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithBrokerVersionFallback(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.AllowAutoCreateTopics()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.DisallowAutoCreateTopics()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSecurityProtocol(SecurityProtocol?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslCipherSuites(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslCurvesList(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslSigalgsList(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslKeyLocation(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslKeyPassword(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslKeyPem(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslCertificateLocation(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslCertificatePem(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslCaLocation(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithHttpsCaLocation(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithHttpsCaPem(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslCaPem(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslCaCertificateStores(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslCrlLocation(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslKeystoreLocation(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslKeystorePassword(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslProviders(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslEngineLocation(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslEngineId(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.EnableSslCertificateVerification()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.DisableSslCertificateVerification()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSslEndpointIdentificationAlgorithm(SslEndpointIdentificationAlgorithm?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslKerberosServiceName(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslKerberosPrincipal(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslKerberosKinitCmd(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslKerberosKeytab(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslKerberosMinTimeBeforeRelogin(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslUsername(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslPassword(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerConfig(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.EnableSaslOauthbearerUnsecureJwt()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.DisableSaslOauthbearerUnsecureJwt()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerMethod(SaslOauthbearerMethod?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerClientId(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerClientSecret(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerScope(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerExtensions(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerTokenEndpointUrl(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerGrantType(SaslOauthbearerGrantType?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionAlgorithm(SaslOauthbearerAssertionAlgorithm?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionPrivateKeyFile(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionPrivateKeyPassphrase(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionPrivateKeyPem(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionFile(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionClaimAud(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionClaimExpSeconds(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionClaimIss(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionClaimJtiInclude(bool?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionClaimNbfSeconds(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionClaimSub(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerAssertionJwtTemplateFile(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithSaslOauthbearerMetadataAuthenticationType(SaslOauthbearerMetadataAuthenticationType?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithPluginLibraryPaths(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithClientRack(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithCancellationDelayMaxMs(int)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithClientId(string)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithRetryBackoffMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithRetryBackoffMaxMs(int?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.WithClientDnsLookup(ClientDnsLookup?)
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.EnableMetricsPush()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.DisableMetricsPush()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.BuildCore()
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.Config
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.This
    object.GetType()
    object.MemberwiseClone()
    object.ToString()
    object.Equals(object)
    object.Equals(object, object)
    object.ReferenceEquals(object, object)
    object.GetHashCode()
    Namespace: Silverback.Messaging.Configuration.Kafka
    Assembly: Silverback.Integration.Kafka.dll
    Syntax
    public class KafkaClientConfigurationBuilder : KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>

    Constructors

    KafkaClientConfigurationBuilder()

    Builds the KafkaProducerConfiguration.

    Declaration
    public KafkaClientConfigurationBuilder()

    Properties

    This

    Gets this instance.

    Declaration
    protected override KafkaClientConfigurationBuilder This { get; }
    Property Value
    Type Description
    KafkaClientConfigurationBuilder
    Overrides
    KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>.This
    Remarks

    This is necessary to work around casting in the base classes.

    Methods

    Build()

    Builds the KafkaClientConfiguration instance.

    Declaration
    public KafkaClientConfiguration Build()
    Returns
    Type Description
    KafkaClientConfiguration

    The KafkaClientConfiguration.

    GitHub E-Mail
    ↑ Back to top © 2026 Sergio Aquilini