Class MockedConfluentProducerBuilder

The builder for the Silverback.Messaging.Broker.Kafka.Mocks.MockedConfluentProducer.

Inheritance
System.Object
MockedConfluentProducerBuilder
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.Messaging.Broker.Kafka
Assembly: Silverback.Integration.Kafka.Testing.dll
Syntax
public class MockedConfluentProducerBuilder : IConfluentProducerBuilder

Constructors

| Improve this doc View source

MockedConfluentProducerBuilder(IServiceProvider)

Initializes a new instance of the MockedConfluentProducerBuilder class.

Declaration
public MockedConfluentProducerBuilder(IServiceProvider serviceProvider)
Parameters
Type Name Description
System.IServiceProvider serviceProvider

The System.IServiceProvider to be used to resolve the required services.

Methods

| Improve this doc View source

Build()

Declaration
public IProducer<byte[], byte[]> Build()
Returns
Type Description
Confluent.Kafka.IProducer<System.Byte[], System.Byte[]>
| Improve this doc View source

SetConfig(ProducerConfig)

Declaration
public IConfluentProducerBuilder SetConfig(ProducerConfig config)
Parameters
Type Name Description
Confluent.Kafka.ProducerConfig config
Returns
Type Description
IConfluentProducerBuilder
| Improve this doc View source

SetLogHandler(Action<IProducer<Byte[], Byte[]>, LogMessage>)

Declaration
public IConfluentProducerBuilder SetLogHandler(Action<IProducer<byte[], byte[]>, LogMessage> logHandler)
Parameters
Type Name Description
System.Action<Confluent.Kafka.IProducer<System.Byte[], System.Byte[]>, Confluent.Kafka.LogMessage> logHandler
Returns
Type Description
IConfluentProducerBuilder
| Improve this doc View source

SetStatisticsHandler(Action<IProducer<Byte[], Byte[]>, String>)

Declaration
public IConfluentProducerBuilder SetStatisticsHandler(Action<IProducer<byte[], byte[]>, string> statisticsHandler)
Parameters
Type Name Description
System.Action<Confluent.Kafka.IProducer<System.Byte[], System.Byte[]>, System.String> statisticsHandler
Returns
Type Description
IConfluentProducerBuilder

Implements