Class MockedConfluentConsumerBuilder

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

Inheritance
System.Object
MockedConfluentConsumerBuilder
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 MockedConfluentConsumerBuilder : IConfluentConsumerBuilder

Constructors

| Improve this doc View source

MockedConfluentConsumerBuilder(IServiceProvider, IMockedKafkaOptions)

Initializes a new instance of the MockedConfluentConsumerBuilder class.

Declaration
public MockedConfluentConsumerBuilder(IServiceProvider serviceProvider, IMockedKafkaOptions options)
Parameters
Type Name Description
System.IServiceProvider serviceProvider

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

The IMockedKafkaOptions.

Methods

| Improve this doc View source

Build()

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

SetConfig(ConsumerConfig)

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

SetErrorHandler(Action<IConsumer<Byte[], Byte[]>, Error>)

Declaration
public IConfluentConsumerBuilder SetErrorHandler(Action<IConsumer<byte[], byte[]>, Error> errorHandler)
Parameters
Type Name Description
System.Action<Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>, Confluent.Kafka.Error> errorHandler
Returns
Type Description
IConfluentConsumerBuilder
| Improve this doc View source

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

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

SetOffsetsCommittedHandler(Action<IConsumer<Byte[], Byte[]>, CommittedOffsets>)

Declaration
public IConfluentConsumerBuilder SetOffsetsCommittedHandler(Action<IConsumer<byte[], byte[]>, CommittedOffsets> offsetsCommittedHandler)
Parameters
Type Name Description
System.Action<Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>, Confluent.Kafka.CommittedOffsets> offsetsCommittedHandler
Returns
Type Description
IConfluentConsumerBuilder
| Improve this doc View source

SetPartitionsAssignedHandler(Action<IConsumer<Byte[], Byte[]>, List<TopicPartition>>)

Declaration
public IConfluentConsumerBuilder SetPartitionsAssignedHandler(Action<IConsumer<byte[], byte[]>, List<TopicPartition>> partitionsAssignedHandler)
Parameters
Type Name Description
System.Action<Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>, System.Collections.Generic.List<Confluent.Kafka.TopicPartition>> partitionsAssignedHandler
Returns
Type Description
IConfluentConsumerBuilder
| Improve this doc View source

SetPartitionsAssignedHandler(Func<IConsumer<Byte[], Byte[]>, List<TopicPartition>, IEnumerable<TopicPartitionOffset>>)

Declaration
public IConfluentConsumerBuilder SetPartitionsAssignedHandler(Func<IConsumer<byte[], byte[]>, List<TopicPartition>, IEnumerable<TopicPartitionOffset>> partitionsAssignedHandler)
Parameters
Type Name Description
System.Func<Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>, System.Collections.Generic.List<Confluent.Kafka.TopicPartition>, System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartitionOffset>> partitionsAssignedHandler
Returns
Type Description
IConfluentConsumerBuilder
| Improve this doc View source

SetPartitionsRevokedHandler(Action<IConsumer<Byte[], Byte[]>, List<TopicPartitionOffset>>)

Declaration
public IConfluentConsumerBuilder SetPartitionsRevokedHandler(Action<IConsumer<byte[], byte[]>, List<TopicPartitionOffset>> partitionsRevokedHandler)
Parameters
Type Name Description
System.Action<Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>, System.Collections.Generic.List<Confluent.Kafka.TopicPartitionOffset>> partitionsRevokedHandler
Returns
Type Description
IConfluentConsumerBuilder
| Improve this doc View source

SetPartitionsRevokedHandler(Func<IConsumer<Byte[], Byte[]>, List<TopicPartitionOffset>, IEnumerable<TopicPartitionOffset>>)

Declaration
public IConfluentConsumerBuilder SetPartitionsRevokedHandler(Func<IConsumer<byte[], byte[]>, List<TopicPartitionOffset>, IEnumerable<TopicPartitionOffset>> partitionsRevokedHandler)
Parameters
Type Name Description
System.Func<Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>, System.Collections.Generic.List<Confluent.Kafka.TopicPartitionOffset>, System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartitionOffset>> partitionsRevokedHandler
Returns
Type Description
IConfluentConsumerBuilder
| Improve this doc View source

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

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

Implements