Class KafkaClientConfigurationBuilder

Namespace

Silverback.Messaging.Configuration.Kafka

Assembly

Silverback.Integration.Kafka.dll

Builds the KafkaProducerConfiguration.

public class KafkaClientConfigurationBuilder : KafkaClientConfigurationBuilder<KafkaClientConfiguration, ClientConfig, KafkaClientConfigurationBuilder>

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()

Constructors

KafkaClientConfigurationBuilder()

public KafkaClientConfigurationBuilder()

Properties

This

Gets this instance.

protected override KafkaClientConfigurationBuilder This { get; }

Property Value

KafkaClientConfigurationBuilder

Remarks

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

Methods

Build()

Builds the KafkaClientConfiguration instance.

public KafkaClientConfiguration Build()

Returns

KafkaClientConfiguration

The KafkaClientConfiguration.