Class ConfluentConsumerBuilder

Namespace

Silverback.Messaging.Broker.Kafka

Assembly

Silverback.Integration.Kafka.dll

Wraps the Confluent.Kafka.ConsumerBuilder<TKey, TValue>.

public class ConfluentConsumerBuilder : IConfluentConsumerBuilder

Inheritance

object

ConfluentConsumerBuilder

Implements

IConfluentConsumerBuilder

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ConfluentConsumerBuilder()

public ConfluentConsumerBuilder()

Methods

Build()

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

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

Returns

IConsumer<byte[], byte[]>

The Confluent.Kafka.IConsumer<TKey, TValue>.

SetConfig(ConsumerConfig)

Sets the consumer configuration.

public IConfluentConsumerBuilder SetConfig(ConsumerConfig config)

Parameters

config ConsumerConfig

The configuration.

Returns

IConfluentConsumerBuilder

The IConfluentConsumerBuilder so that additional calls can be chained.

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

Sets the handler to call on error events.

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

Parameters

errorHandler Action<IConsumer<byte[], byte[]>, Error>

The event handler.

Returns

IConfluentConsumerBuilder

The IConfluentConsumerBuilder so that additional calls can be chained.

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.

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

Parameters

logHandler Action<IConsumer<byte[], byte[]>, LogMessage>

The event handler.

Returns

IConfluentConsumerBuilder

The IConfluentConsumerBuilder so that additional calls can be chained.

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

Sets the handler to call on offsets committed events.

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

Parameters

offsetsCommittedHandler Action<IConsumer<byte[], byte[]>, CommittedOffsets>

The event handler.

Returns

IConfluentConsumerBuilder

The IConfluentConsumerBuilder so that additional calls can be chained.

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

Sets the handler to call on partitions assigned events.

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

Parameters

partitionsAssignedHandler Action<IConsumer<byte[], byte[]>, List<TopicPartition>>

The event handler.

Returns

IConfluentConsumerBuilder

The IConfluentConsumerBuilder so that additional calls can be chained.

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

Sets the handler to call on partitions assigned events.

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

Parameters

partitionsAssignedHandler Func<IConsumer<byte[], byte[]>, List<TopicPartition>, IEnumerable<TopicPartitionOffset>>

The event handler.

Returns

IConfluentConsumerBuilder

The IConfluentConsumerBuilder so that additional calls can be chained.

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

Sets the handler to call on partitions revoked events.

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

Parameters

partitionsRevokedHandler Action<IConsumer<byte[], byte[]>, List<TopicPartitionOffset>>

The event handler.

Returns

IConfluentConsumerBuilder

The IConfluentConsumerBuilder so that additional calls can be chained.

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

Sets the handler to call on partitions revoked events.

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

Parameters

partitionsRevokedHandler Func<IConsumer<byte[], byte[]>, List<TopicPartitionOffset>, IEnumerable<TopicPartitionOffset>>

The event handler.

Returns

IConfluentConsumerBuilder

The IConfluentConsumerBuilder so that additional calls can be chained.

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

Sets the handler to call on statistics events.

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

Parameters

statisticsHandler Action<IConsumer<byte[], byte[]>, string>

The event handler.

Returns

IConfluentConsumerBuilder

The IConfluentConsumerBuilder so that additional calls can be chained.