Class MockedConfluentConsumerBuilder

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

Inheritance

object

MockedConfluentConsumerBuilder

Implements

IConfluentConsumerBuilder

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

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
IServiceProvider	serviceProvider	The IServiceProvider to be used to resolve the required services.
IMockedKafkaOptions	options	The IMockedKafkaOptions.

Methods

| Improve this doc View source

Build()

Builds the Confluent.Kafka.IConsumer<TKey, TValue> instance.

Declaration

public IConsumer<byte[]?, byte[]?> Build()

Returns

Type	Description
IConsumer<byte[], byte[]>	The Confluent.Kafka.IConsumer<TKey, TValue>.

| Improve this doc View source

SetConfig(ConsumerConfig)

Sets the consumer configuration.

Declaration

public IConfluentConsumerBuilder SetConfig(ConsumerConfig config)

Parameters

Type	Name	Description
ConsumerConfig	config	The configuration.

Returns

Type	Description
IConfluentConsumerBuilder	The IConfluentProducerBuilder so that additional calls can be chained.

| Improve this doc View source

SetErrorHandler(Action<IConsumer<byte[]?, byte[]?>, Error>)

Sets the handler to call on error events.

Declaration

public IConfluentConsumerBuilder SetErrorHandler(Action<IConsumer<byte[]?, byte[]?>, Error> errorHandler)

Parameters

Type	Name	Description
Action<IConsumer<byte[], byte[]>, Error>	errorHandler	The event handler.

Returns

Type	Description
IConfluentConsumerBuilder	The IConfluentProducerBuilder so that additional calls can be chained.

| Improve this doc View source

SetLogHandler(Action<IConsumer<byte[]?, byte[]?>, LogMessage>)

Set the handler to call when there is information available to be logged. If not specified, a default callback that writes to stderr will be used.

Declaration

public IConfluentConsumerBuilder SetLogHandler(Action<IConsumer<byte[]?, byte[]?>, LogMessage> logHandler)

Parameters

Type	Name	Description
Action<IConsumer<byte[], byte[]>, LogMessage>	logHandler	The event handler.

Returns

Type	Description
IConfluentConsumerBuilder	The IConfluentProducerBuilder so that additional calls can be chained.

| Improve this doc View source

SetOffsetsCommittedHandler(Action<IConsumer<byte[]?, byte[]?>, CommittedOffsets>)

Sets the handler to call on offsets committed events.

Declaration

public IConfluentConsumerBuilder SetOffsetsCommittedHandler(Action<IConsumer<byte[]?, byte[]?>, CommittedOffsets> offsetsCommittedHandler)

Parameters

Type	Name	Description
Action<IConsumer<byte[], byte[]>, CommittedOffsets>	offsetsCommittedHandler	The event handler.

Returns

Type	Description
IConfluentConsumerBuilder	The IConfluentProducerBuilder so that additional calls can be chained.

| Improve this doc View source

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

Sets the handler to call on partitions assigned events.

Declaration

public IConfluentConsumerBuilder SetPartitionsAssignedHandler(Action<IConsumer<byte[]?, byte[]?>, List<TopicPartition>> partitionsAssignedHandler)

Parameters

Type	Name	Description
Action<IConsumer<byte[], byte[]>, List<TopicPartition>>	partitionsAssignedHandler	The event handler.

Returns

Type	Description
IConfluentConsumerBuilder	The IConfluentProducerBuilder so that additional calls can be chained.

| Improve this doc View source

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

Sets the handler to call on partitions assigned events.

Declaration

public IConfluentConsumerBuilder SetPartitionsAssignedHandler(Func<IConsumer<byte[]?, byte[]?>, List<TopicPartition>, IEnumerable<TopicPartitionOffset>> partitionsAssignedHandler)

Parameters

Type	Name	Description
Func<IConsumer<byte[], byte[]>, List<TopicPartition>, IEnumerable<TopicPartitionOffset>>	partitionsAssignedHandler	The event handler.

Returns

Type	Description
IConfluentConsumerBuilder	The IConfluentProducerBuilder so that additional calls can be chained.

| Improve this doc View source

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

Sets the handler to call on partitions revoked events.

Declaration

public IConfluentConsumerBuilder SetPartitionsRevokedHandler(Action<IConsumer<byte[]?, byte[]?>, List<TopicPartitionOffset>> partitionsRevokedHandler)

Parameters

Type	Name	Description
Action<IConsumer<byte[], byte[]>, List<TopicPartitionOffset>>	partitionsRevokedHandler	The event handler.

Returns

Type	Description
IConfluentConsumerBuilder	The IConfluentProducerBuilder so that additional calls can be chained.

| Improve this doc View source

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

Sets the handler to call on partitions revoked events.

Declaration

public IConfluentConsumerBuilder SetPartitionsRevokedHandler(Func<IConsumer<byte[]?, byte[]?>, List<TopicPartitionOffset>, IEnumerable<TopicPartitionOffset>> partitionsRevokedHandler)

Parameters

Type	Name	Description
Func<IConsumer<byte[], byte[]>, List<TopicPartitionOffset>, IEnumerable<TopicPartitionOffset>>	partitionsRevokedHandler	The event handler.

Returns

Type	Description
IConfluentConsumerBuilder	The IConfluentProducerBuilder so that additional calls can be chained.

| Improve this doc View source

SetStatisticsHandler(Action<IConsumer<byte[]?, byte[]?>, string>)

Sets the handler to call on statistics events.

Declaration

public IConfluentConsumerBuilder SetStatisticsHandler(Action<IConsumer<byte[]?, byte[]?>, string> statisticsHandler)

Parameters

Type	Name	Description
Action<IConsumer<byte[], byte[]>, string>	statisticsHandler	The event handler.

Returns

Type	Description
IConfluentConsumerBuilder	The IConfluentProducerBuilder so that additional calls can be chained.

Implements

IConfluentConsumerBuilder