Class PostgreSqlKafkaOffsetStoreSettingsBuilder

Namespace

Silverback.Messaging.Configuration

Assembly

Silverback.Storage.PostgreSql.dll

Builds the PostgreSqlKafkaOffsetStoreSettings.

public class PostgreSqlKafkaOffsetStoreSettingsBuilder : IKafkaOffsetStoreSettingsImplementationBuilder

Inheritance

object

PostgreSqlKafkaOffsetStoreSettingsBuilder

Implements

IKafkaOffsetStoreSettingsImplementationBuilder

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

PostgreSqlKafkaOffsetStoreSettingsBuilder(string)

Initializes a new instance of the PostgreSqlKafkaOffsetStoreSettingsBuilder class.

public PostgreSqlKafkaOffsetStoreSettingsBuilder(string connectionString)

Parameters

connectionString string

The connection string to the PostgreSql database.

Methods

Build()

Builds the settings instance.

public KafkaOffsetStoreSettings Build()

Returns

KafkaOffsetStoreSettings

The KafkaOffsetStoreSettings.

UseTable(string)

Sets the table name.

public PostgreSqlKafkaOffsetStoreSettingsBuilder UseTable(string tableName)

Parameters

tableName string

The name of the Kafka offset store table. If not specified, the default "SilverbackKafkaOffsets" will be used.

Returns

PostgreSqlKafkaOffsetStoreSettingsBuilder

The PostgreSqlKafkaOffsetStoreSettingsBuilder so that additional calls can be chained.

WithCreateTableTimeout(TimeSpan)

Sets the timeout for the table creation.

public PostgreSqlKafkaOffsetStoreSettingsBuilder WithCreateTableTimeout(TimeSpan createTableTimeout)

Parameters

createTableTimeout TimeSpan

The timeout for the table creation. The default is 30 seconds.

Returns

PostgreSqlKafkaOffsetStoreSettingsBuilder

The PostgreSqlOutboxSettingsBuilder so that additional calls can be chained.

WithDbCommandTimeout(TimeSpan)

Sets the database command timeout.

public PostgreSqlKafkaOffsetStoreSettingsBuilder WithDbCommandTimeout(TimeSpan dbCommandTimeout)

Parameters

dbCommandTimeout TimeSpan

The timeout for the database commands. The default is 10 seconds.

Returns

PostgreSqlKafkaOffsetStoreSettingsBuilder

The PostgreSqlOutboxSettingsBuilder so that additional calls can be chained.