Class KafkaTestingHelper

Inheritance
System.Object
TestingHelper<KafkaBroker>
KafkaTestingHelper
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Testing
Assembly: Silverback.Integration.Kafka.Testing.dll
Syntax
public class KafkaTestingHelper : TestingHelper<KafkaBroker>, IKafkaTestingHelper, ITestingHelper<KafkaBroker>

Constructors

| Improve this doc View source

KafkaTestingHelper(IServiceProvider, ILogger<KafkaTestingHelper>)

Initializes a new instance of the KafkaTestingHelper class.

Declaration
public KafkaTestingHelper(IServiceProvider serviceProvider, ILogger<KafkaTestingHelper> logger)
Parameters
Type Name Description
System.IServiceProvider serviceProvider

The System.IServiceProvider.
Microsoft.Extensions.Logging.ILogger<KafkaTestingHelper> logger

The ISilverbackLogger.

Methods

| Improve this doc View source

GetTopic(String)

Declaration
public IInMemoryTopic GetTopic(string name)
Parameters
Type Name Description
System.String name
Returns
Type Description
IInMemoryTopic
| Improve this doc View source

GetTopic(String, String)

Declaration
public IInMemoryTopic GetTopic(string name, string bootstrapServers)
Parameters
Type Name Description
System.String name
System.String bootstrapServers
Returns
Type Description
IInMemoryTopic
| Improve this doc View source

GetTopics(String, String)

Declaration
public IReadOnlyCollection<IInMemoryTopic> GetTopics(string name, string bootstrapServers = null)
Parameters
Type Name Description
System.String name
System.String bootstrapServers
Returns
Type Description
System.Collections.Generic.IReadOnlyCollection<IInMemoryTopic>
| Improve this doc View source

WaitUntilAllMessagesAreConsumedAsync(Boolean, IReadOnlyCollection<String>, Nullable<TimeSpan>)

Declaration
public Task WaitUntilAllMessagesAreConsumedAsync(bool throwTimeoutException, IReadOnlyCollection<string> topicNames, TimeSpan? timeout = null)
Parameters
Type Name Description
System.Boolean throwTimeoutException
System.Collections.Generic.IReadOnlyCollection<System.String> topicNames
System.Nullable<System.TimeSpan> timeout
Returns
Type Description
System.Threading.Tasks.Task
| Improve this doc View source

WaitUntilAllMessagesAreConsumedAsync(Boolean, Nullable<TimeSpan>)

Declaration
public override Task WaitUntilAllMessagesAreConsumedAsync(bool throwTimeoutException, TimeSpan? timeout = null)
Parameters
Type Name Description
System.Boolean throwTimeoutException
System.Nullable<System.TimeSpan> timeout
Returns
Type Description
System.Threading.Tasks.Task
Overrides
Silverback.Testing.TestingHelper<Silverback.Messaging.Broker.KafkaBroker>.WaitUntilAllMessagesAreConsumedAsync(System.Boolean, System.Nullable<System.TimeSpan>)
| Improve this doc View source

WaitUntilAllMessagesAreConsumedAsync(IReadOnlyCollection<String>, Nullable<TimeSpan>)

Declaration
public Task WaitUntilAllMessagesAreConsumedAsync(IReadOnlyCollection<string> topicNames, TimeSpan? timeout = null)
Parameters
Type Name Description
System.Collections.Generic.IReadOnlyCollection<System.String> topicNames
System.Nullable<System.TimeSpan> timeout
Returns
Type Description
System.Threading.Tasks.Task

Implements