Class KafkaConsumerEndpointBuilder

Inheritance
System.Object
EndpointBuilder<KafkaConsumerEndpoint, IKafkaConsumerEndpointBuilder>
ConsumerEndpointBuilder<KafkaConsumerEndpoint, IKafkaConsumerEndpointBuilder>
KafkaConsumerEndpointBuilder
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.Configuration.Kafka
Assembly: Silverback.Integration.Kafka.dll
Syntax
public class KafkaConsumerEndpointBuilder : ConsumerEndpointBuilder<KafkaConsumerEndpoint, IKafkaConsumerEndpointBuilder>, IKafkaConsumerEndpointBuilder, IConsumerEndpointBuilder<IKafkaConsumerEndpointBuilder>, IEndpointBuilder<IKafkaConsumerEndpointBuilder>

Constructors

| Improve this doc View source

KafkaConsumerEndpointBuilder(KafkaClientConfig, Type, IEndpointsConfigurationBuilder)

Initializes a new instance of the KafkaConsumerEndpointBuilder class.

Declaration
public KafkaConsumerEndpointBuilder(KafkaClientConfig clientConfig = null, Type messageType = null, IEndpointsConfigurationBuilder endpointsConfigurationBuilder = null)
Parameters
Type Name Description
KafkaClientConfig clientConfig

The KafkaClientConfig to be used to initialize the KafkaConsumerConfig.
System.Type messageType

The type of the message being consumed.
IEndpointsConfigurationBuilder endpointsConfigurationBuilder

The optional reference to the IEndpointsConfigurationBuilder that instantiated the builder.

Properties

| Improve this doc View source

This

Declaration
protected override IKafkaConsumerEndpointBuilder This { get; }
Property Value
Type Description
IKafkaConsumerEndpointBuilder
Overrides
Silverback.Messaging.Configuration.EndpointBuilder<Silverback.Messaging.KafkaConsumerEndpoint, Silverback.Messaging.Configuration.Kafka.IKafkaConsumerEndpointBuilder>.This

Methods

| Improve this doc View source

Configure(Action<KafkaConsumerConfig>)

Declaration
public IKafkaConsumerEndpointBuilder Configure(Action<KafkaConsumerConfig> configAction)
Parameters
Type Name Description
System.Action<KafkaConsumerConfig> configAction
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

ConsumeFrom(TopicPartition[])

Declaration
public IKafkaConsumerEndpointBuilder ConsumeFrom(params TopicPartition[] topicPartitions)
Parameters
Type Name Description
Confluent.Kafka.TopicPartition[] topicPartitions
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

ConsumeFrom(TopicPartitionOffset[])

Declaration
public IKafkaConsumerEndpointBuilder ConsumeFrom(params TopicPartitionOffset[] topicPartitions)
Parameters
Type Name Description
Confluent.Kafka.TopicPartitionOffset[] topicPartitions
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

ConsumeFrom(String, Func<IReadOnlyCollection<TopicPartition>, IEnumerable<TopicPartition>>)

Declaration
public IKafkaConsumerEndpointBuilder ConsumeFrom(string topicName, Func<IReadOnlyCollection<TopicPartition>, IEnumerable<TopicPartition>> topicPartitionsResolver)
Parameters
Type Name Description
System.String topicName
System.Func<System.Collections.Generic.IReadOnlyCollection<Confluent.Kafka.TopicPartition>, System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartition>> topicPartitionsResolver
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

ConsumeFrom(String, Func<IReadOnlyCollection<TopicPartition>, IEnumerable<TopicPartitionOffset>>)

Declaration
public IKafkaConsumerEndpointBuilder ConsumeFrom(string topicName, Func<IReadOnlyCollection<TopicPartition>, IEnumerable<TopicPartitionOffset>> topicPartitionsResolver)
Parameters
Type Name Description
System.String topicName
System.Func<System.Collections.Generic.IReadOnlyCollection<Confluent.Kafka.TopicPartition>, System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartitionOffset>> topicPartitionsResolver
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

ConsumeFrom(String[])

Declaration
public IKafkaConsumerEndpointBuilder ConsumeFrom(params string[] topicNames)
Parameters
Type Name Description
System.String[] topicNames
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

ConsumeFrom(String[], Func<IReadOnlyCollection<TopicPartition>, IEnumerable<TopicPartition>>)

Declaration
public IKafkaConsumerEndpointBuilder ConsumeFrom(string[] topicNames, Func<IReadOnlyCollection<TopicPartition>, IEnumerable<TopicPartition>> topicPartitionsResolver)
Parameters
Type Name Description
System.String[] topicNames
System.Func<System.Collections.Generic.IReadOnlyCollection<Confluent.Kafka.TopicPartition>, System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartition>> topicPartitionsResolver
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

ConsumeFrom(String[], Func<IReadOnlyCollection<TopicPartition>, IEnumerable<TopicPartitionOffset>>)

Declaration
public IKafkaConsumerEndpointBuilder ConsumeFrom(string[] topicNames, Func<IReadOnlyCollection<TopicPartition>, IEnumerable<TopicPartitionOffset>> topicPartitionsResolver)
Parameters
Type Name Description
System.String[] topicNames
System.Func<System.Collections.Generic.IReadOnlyCollection<Confluent.Kafka.TopicPartition>, System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartitionOffset>> topicPartitionsResolver
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

CreateEndpoint()

Declaration
protected override KafkaConsumerEndpoint CreateEndpoint()
Returns
Type Description
KafkaConsumerEndpoint
Overrides
Silverback.Messaging.Configuration.EndpointBuilder<Silverback.Messaging.KafkaConsumerEndpoint, Silverback.Messaging.Configuration.Kafka.IKafkaConsumerEndpointBuilder>.CreateEndpoint()
| Improve this doc View source

LimitBackpressure(Int32)

Declaration
public IKafkaConsumerEndpointBuilder LimitBackpressure(int backpressureLimit)
Parameters
Type Name Description
System.Int32 backpressureLimit
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

LimitParallelism(Int32)

Declaration
public IKafkaConsumerEndpointBuilder LimitParallelism(int maxDegreeOfParallelism)
Parameters
Type Name Description
System.Int32 maxDegreeOfParallelism
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

ProcessAllPartitionsTogether()

Declaration
public IKafkaConsumerEndpointBuilder ProcessAllPartitionsTogether()
Returns
Type Description
IKafkaConsumerEndpointBuilder
| Improve this doc View source

ProcessPartitionsIndependently()

Declaration
public IKafkaConsumerEndpointBuilder ProcessPartitionsIndependently()
Returns
Type Description
IKafkaConsumerEndpointBuilder

Implements

Extension Methods