Interface IMockedKafkaOptions

Stores the mocked Kafka configuration.

Namespace: Silverback.Messaging.Configuration.Kafka

Assembly: Silverback.Integration.Kafka.Testing.dll

Syntax

public interface IMockedKafkaOptions

Properties

| Improve this doc View source

DefaultPartitionsCount

Gets or sets the default number of partitions to be created per each topic. The default is 5.

Declaration

int DefaultPartitionsCount { get; set; }

Property Value

Type	Description
int

| Improve this doc View source

OverriddenAutoCommitIntervalMs

Gets or sets the value to be used instead of the default 5 seconds or the configured"ConfluentConsumerConfigProxy.AutoCommitIntervalMs" /> for the inbound topics. Set it to null to disable the feature. The default is 50 milliseconds.

Declaration

int? OverriddenAutoCommitIntervalMs { get; set; }

Property Value

Type	Description
int?

| Improve this doc View source

PartitionsAssignmentDelay

Gets or sets the delay to be applied before and assigning the partitions.

Declaration

TimeSpan PartitionsAssignmentDelay { get; set; }

Property Value

Type	Description
TimeSpan

| Improve this doc View source

TopicPartitionsCount

Gets the number of partitions created for the given topic. If not specified for a topic the DefaultPartitionsCount will be used.

Declaration

IDictionary<string, int> TopicPartitionsCount { get; }

Property Value

Type	Description
IDictionary<string, int>