Class SqliteKafkaOffsetStoreSettingsBuilder

Namespace

Silverback.Messaging.Configuration

Assembly

Silverback.Storage.Sqlite.dll

Builds the SqliteKafkaOffsetStoreSettings.

public class SqliteKafkaOffsetStoreSettingsBuilder : IKafkaOffsetStoreSettingsImplementationBuilder

Inheritance

object

SqliteKafkaOffsetStoreSettingsBuilder

Implements

IKafkaOffsetStoreSettingsImplementationBuilder

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

SqliteKafkaOffsetStoreSettingsBuilder(string)

Initializes a new instance of the SqliteKafkaOffsetStoreSettingsBuilder class.

public SqliteKafkaOffsetStoreSettingsBuilder(string connectionString)

Parameters

connectionString string

The connection string to the SQLite database.

Methods

Build()

Builds the settings instance.

public KafkaOffsetStoreSettings Build()

Returns

KafkaOffsetStoreSettings

The KafkaOffsetStoreSettings.

UseTable(string)

Sets the table name.

public SqliteKafkaOffsetStoreSettingsBuilder UseTable(string tableName)

Parameters

tableName string

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

Returns

SqliteKafkaOffsetStoreSettingsBuilder

The SqliteKafkaOffsetStoreSettingsBuilder so that additional calls can be chained.

WithCreateTableTimeout(TimeSpan)

Sets the timeout for the table creation.

public SqliteKafkaOffsetStoreSettingsBuilder WithCreateTableTimeout(TimeSpan createTableTimeout)

Parameters

createTableTimeout TimeSpan

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

Returns

SqliteKafkaOffsetStoreSettingsBuilder

The SqliteOutboxSettingsBuilder so that additional calls can be chained.

WithDbCommandTimeout(TimeSpan)

Sets the database command timeout.

public SqliteKafkaOffsetStoreSettingsBuilder WithDbCommandTimeout(TimeSpan dbCommandTimeout)

Parameters

dbCommandTimeout TimeSpan

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

Returns

SqliteKafkaOffsetStoreSettingsBuilder

The SqliteOutboxSettingsBuilder so that additional calls can be chained.