Class KafkaProducerConfig
Extends the Confluent.Kafka.ProducerConfig adding the Silverback specific settings.
Inheritance
System.Object
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()
Assembly: Silverback.Integration.Kafka.dll
Syntax
public sealed class KafkaProducerConfig : ConfluentProducerConfigProxy, IValidatableEndpointSettings, IEquatable<KafkaProducerConfig>
Constructors
|
Improve this doc
View source
KafkaProducerConfig(KafkaClientConfig)
Declaration
public KafkaProducerConfig(KafkaClientConfig clientConfig = null)
Parameters
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
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>