Class KafkaProducerConfig

Extends the Confluent.Kafka.ProducerConfig adding the Silverback specific settings.

Inheritance
System.Object
ConfluentClientConfigProxy
ConfluentProducerConfigProxy
KafkaProducerConfig
Implements
System.IEquatable<KafkaProducerConfig>
Inherited Members
System.Object.Equals(System.Object, System.Object)
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Messaging.Configuration.Kafka
Assembly: Silverback.Integration.Kafka.dll
Syntax
public sealed class KafkaProducerConfig : ConfluentProducerConfigProxy, IValidatableEndpointSettings, IEquatable<KafkaProducerConfig>

Constructors

| Improve this doc View source

KafkaProducerConfig(KafkaClientConfig)

Initializes a new instance of the KafkaProducerConfig class.

Declaration
public KafkaProducerConfig(KafkaClientConfig clientConfig = null)
Parameters
Type Name Description
KafkaClientConfig clientConfig

The KafkaClientConfig to be used to initialize the KafkaProducerConfig.

Properties

| Improve this doc View source

AreDeliveryReportsEnabled

Gets a value indicating whether delivery reports are enabled according to the explicit configuration and Kafka defaults.

Declaration
public bool AreDeliveryReportsEnabled { get; }
Property Value
Type Description
System.Boolean
| Improve this doc View source

DisposeOnException

Specifies whether the producer has to be disposed and recreated if a Confluent.Kafka.KafkaException is thrown. The default is true.

Declaration
public bool DisposeOnException { get; set; }
Property Value
Type Description
System.Boolean
| Improve this doc View source

FlushTimeout

Specifies the flush operation timeout. The default is 30 seconds.

Declaration
public TimeSpan FlushTimeout { get; set; }
Property Value
Type Description
System.TimeSpan
| Improve this doc View source

ThrowIfNotAcknowledged

Specifies whether an exception must be thrown by the producer if the persistence is not acknowledge by the broker. The default is true.

Declaration
public bool ThrowIfNotAcknowledged { get; set; }
Property Value
Type Description
System.Boolean
| Improve this doc View source

TransactionInitTimeout

The transactions init operation timeout. The default is 30 seconds.

Declaration
public TimeSpan TransactionInitTimeout { get; set; }
Property Value
Type Description
System.TimeSpan

Methods

| Improve this doc View source

Equals(KafkaProducerConfig)

Declaration
public bool Equals(KafkaProducerConfig other)
Parameters
Type Name Description
KafkaProducerConfig other
Returns
Type Description
System.Boolean
| Improve this doc View source

Equals(Object)

Declaration
public override bool Equals(object obj)
Parameters
Type Name Description
System.Object obj
Returns
Type Description
System.Boolean
Overrides
System.Object.Equals(System.Object)
| Improve this doc View source

GetHashCode()

Declaration
public override int GetHashCode()
Returns
Type Description
System.Int32
Overrides
System.Object.GetHashCode()
| Improve this doc View source

Validate()

Declaration
public override void Validate()
Overrides

Implements

System.IEquatable<T>