Show / Hide Table of Contents

    Class KafkaClientConfig

    Wraps the Confluent.Kafka.ConsumerConfig and contains the properties shared between the KafkaProducerConfig and KafkaConsumerConfig.

    Inheritance
    object
    ConfluentClientConfigProxy
    KafkaClientConfig
    Implements
    IValidatableEndpointSettings
    Inherited Members
    ConfluentClientConfigProxy.SaslMechanism
    ConfluentClientConfigProxy.Acks
    ConfluentClientConfigProxy.ClientId
    ConfluentClientConfigProxy.BootstrapServers
    ConfluentClientConfigProxy.MessageMaxBytes
    ConfluentClientConfigProxy.MessageCopyMaxBytes
    ConfluentClientConfigProxy.ReceiveMessageMaxBytes
    ConfluentClientConfigProxy.MaxInFlight
    ConfluentClientConfigProxy.TopicMetadataRefreshIntervalMs
    ConfluentClientConfigProxy.MetadataMaxAgeMs
    ConfluentClientConfigProxy.TopicMetadataRefreshFastIntervalMs
    ConfluentClientConfigProxy.TopicMetadataRefreshSparse
    ConfluentClientConfigProxy.TopicMetadataPropagationMaxMs
    ConfluentClientConfigProxy.TopicBlacklist
    ConfluentClientConfigProxy.Debug
    ConfluentClientConfigProxy.SocketTimeoutMs
    ConfluentClientConfigProxy.SocketSendBufferBytes
    ConfluentClientConfigProxy.SocketReceiveBufferBytes
    ConfluentClientConfigProxy.SocketKeepaliveEnable
    ConfluentClientConfigProxy.SocketNagleDisable
    ConfluentClientConfigProxy.SocketMaxFails
    ConfluentClientConfigProxy.BrokerAddressTtl
    ConfluentClientConfigProxy.BrokerAddressFamily
    ConfluentClientConfigProxy.SocketConnectionSetupTimeoutMs
    ConfluentClientConfigProxy.ConnectionsMaxIdleMs
    ConfluentClientConfigProxy.ReconnectBackoffMs
    ConfluentClientConfigProxy.ReconnectBackoffMaxMs
    ConfluentClientConfigProxy.StatisticsIntervalMs
    ConfluentClientConfigProxy.LogQueue
    ConfluentClientConfigProxy.LogThreadName
    ConfluentClientConfigProxy.EnableRandomSeed
    ConfluentClientConfigProxy.LogConnectionClose
    ConfluentClientConfigProxy.InternalTerminationSignal
    ConfluentClientConfigProxy.ApiVersionRequest
    ConfluentClientConfigProxy.ApiVersionRequestTimeoutMs
    ConfluentClientConfigProxy.ApiVersionFallbackMs
    ConfluentClientConfigProxy.BrokerVersionFallback
    ConfluentClientConfigProxy.AllowAutoCreateTopics
    ConfluentClientConfigProxy.SecurityProtocol
    ConfluentClientConfigProxy.SslCipherSuites
    ConfluentClientConfigProxy.SslCurvesList
    ConfluentClientConfigProxy.SslSigalgsList
    ConfluentClientConfigProxy.SslKeyLocation
    ConfluentClientConfigProxy.SslKeyPassword
    ConfluentClientConfigProxy.SslKeyPem
    ConfluentClientConfigProxy.SslCertificateLocation
    ConfluentClientConfigProxy.SslCertificatePem
    ConfluentClientConfigProxy.SslCaLocation
    ConfluentClientConfigProxy.SslCaPem
    ConfluentClientConfigProxy.SslCaCertificateStores
    ConfluentClientConfigProxy.SslCrlLocation
    ConfluentClientConfigProxy.SslKeystoreLocation
    ConfluentClientConfigProxy.SslKeystorePassword
    ConfluentClientConfigProxy.SslProviders
    ConfluentClientConfigProxy.SslEngineLocation
    ConfluentClientConfigProxy.SslEngineId
    ConfluentClientConfigProxy.EnableSslCertificateVerification
    ConfluentClientConfigProxy.SslEndpointIdentificationAlgorithm
    ConfluentClientConfigProxy.SaslKerberosServiceName
    ConfluentClientConfigProxy.SaslKerberosPrincipal
    ConfluentClientConfigProxy.SaslKerberosKinitCmd
    ConfluentClientConfigProxy.SaslKerberosKeytab
    ConfluentClientConfigProxy.SaslKerberosMinTimeBeforeRelogin
    ConfluentClientConfigProxy.SaslUsername
    ConfluentClientConfigProxy.SaslPassword
    ConfluentClientConfigProxy.SaslOauthbearerConfig
    ConfluentClientConfigProxy.EnableSaslOauthbearerUnsecureJwt
    ConfluentClientConfigProxy.SaslOauthbearerMethod
    ConfluentClientConfigProxy.SaslOauthbearerClientId
    ConfluentClientConfigProxy.SaslOauthbearerClientSecret
    ConfluentClientConfigProxy.SaslOauthbearerScope
    ConfluentClientConfigProxy.SaslOauthbearerExtensions
    ConfluentClientConfigProxy.SaslOauthbearerTokenEndpointUrl
    ConfluentClientConfigProxy.PluginLibraryPaths
    ConfluentClientConfigProxy.ClientRack
    ConfluentClientConfigProxy.ClientDnsLookup
    ConfluentClientConfigProxy.CancellationDelayMaxMs
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Silverback.Messaging.Configuration.Kafka
    Assembly: Silverback.Integration.Kafka.dll
    Syntax
    public sealed class KafkaClientConfig : ConfluentClientConfigProxy, IValidatableEndpointSettings

    Constructors

    | Improve this doc View source

    KafkaClientConfig()

    Initializes a new instance of the KafkaClientConfig class.

    Declaration
    public KafkaClientConfig()

    Methods

    | Improve this doc View source

    Validate()

    Throws an EndpointConfigurationException if the current configuration is not valid.

    Declaration
    public override void Validate()
    Overrides
    ConfluentClientConfigProxy.Validate()

    Implements

    IValidatableEndpointSettings
    • Improve this doc
    • View source
    GitHub E-Mail
    ↑ Back to top © 2020 Sergio Aquilini