Class KafkaProducerEndpointBuilder

Inheritance
System.Object
EndpointBuilder<KafkaProducerEndpoint, IKafkaProducerEndpointBuilder>
ProducerEndpointBuilder<KafkaProducerEndpoint, IKafkaProducerEndpointBuilder>
KafkaProducerEndpointBuilder
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 KafkaProducerEndpointBuilder : ProducerEndpointBuilder<KafkaProducerEndpoint, IKafkaProducerEndpointBuilder>, IKafkaProducerEndpointBuilder, IProducerEndpointBuilder<IKafkaProducerEndpointBuilder>, IEndpointBuilder<IKafkaProducerEndpointBuilder>

Constructors

| Improve this doc View source

KafkaProducerEndpointBuilder(KafkaClientConfig, Type, IEndpointsConfigurationBuilder)

Initializes a new instance of the KafkaProducerEndpointBuilder class.

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

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

The type of the message being produced.
IEndpointsConfigurationBuilder endpointsConfigurationBuilder

The optional reference to the IEndpointsConfigurationBuilder that instantiated the builder.

Properties

| Improve this doc View source

This

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

Methods

| Improve this doc View source

Configure(Action<KafkaProducerConfig>)

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

CreateEndpoint()

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

ProduceTo(Func<IOutboundEnvelope, IServiceProvider, String>, Func<IOutboundEnvelope, IServiceProvider, Int32>)

Declaration
public IKafkaProducerEndpointBuilder ProduceTo(Func<IOutboundEnvelope, IServiceProvider, string> topicNameFunction, Func<IOutboundEnvelope, IServiceProvider, int> partitionFunction = null)
Parameters
Type Name Description
System.Func<IOutboundEnvelope, System.IServiceProvider, System.String> topicNameFunction
System.Func<IOutboundEnvelope, System.IServiceProvider, System.Int32> partitionFunction
Returns
Type Description
IKafkaProducerEndpointBuilder
| Improve this doc View source

ProduceTo(Func<IOutboundEnvelope, String>, Func<IOutboundEnvelope, Int32>)

Declaration
public IKafkaProducerEndpointBuilder ProduceTo(Func<IOutboundEnvelope, string> topicNameFunction, Func<IOutboundEnvelope, int> partitionFunction = null)
Parameters
Type Name Description
System.Func<IOutboundEnvelope, System.String> topicNameFunction
System.Func<IOutboundEnvelope, System.Int32> partitionFunction
Returns
Type Description
IKafkaProducerEndpointBuilder
| Improve this doc View source

ProduceTo(String, Func<IOutboundEnvelope, String[]>, Func<IOutboundEnvelope, Int32>)

Declaration
public IKafkaProducerEndpointBuilder ProduceTo(string topicNameFormatString, Func<IOutboundEnvelope, string[]> topicNameArgumentsFunction, Func<IOutboundEnvelope, int> partitionFunction = null)
Parameters
Type Name Description
System.String topicNameFormatString
System.Func<IOutboundEnvelope, System.String[]> topicNameArgumentsFunction
System.Func<IOutboundEnvelope, System.Int32> partitionFunction
Returns
Type Description
IKafkaProducerEndpointBuilder
| Improve this doc View source

ProduceTo(String, Nullable<Int32>)

Declaration
public IKafkaProducerEndpointBuilder ProduceTo(string topicName, int? partition = null)
Parameters
Type Name Description
System.String topicName
System.Nullable<System.Int32> partition
Returns
Type Description
IKafkaProducerEndpointBuilder
| Improve this doc View source

ProduceTo<TMessage>(Func<IOutboundEnvelope<TMessage>, IServiceProvider, String>, Func<IOutboundEnvelope<TMessage>, IServiceProvider, Int32>)

Declaration
public IKafkaProducerEndpointBuilder ProduceTo<TMessage>(Func<IOutboundEnvelope<TMessage>, IServiceProvider, string> topicNameFunction, Func<IOutboundEnvelope<TMessage>, IServiceProvider, int> partitionFunction = null)

    where TMessage : class
Parameters
Type Name Description
System.Func<IOutboundEnvelope<TMessage>, System.IServiceProvider, System.String> topicNameFunction
System.Func<IOutboundEnvelope<TMessage>, System.IServiceProvider, System.Int32> partitionFunction
Returns
Type Description
IKafkaProducerEndpointBuilder
Type Parameters
Name Description
TMessage
| Improve this doc View source

ProduceTo<TMessage>(Func<IOutboundEnvelope<TMessage>, String>, Func<IOutboundEnvelope<TMessage>, Int32>)

Declaration
public IKafkaProducerEndpointBuilder ProduceTo<TMessage>(Func<IOutboundEnvelope<TMessage>, string> topicNameFunction, Func<IOutboundEnvelope<TMessage>, int> partitionFunction = null)

    where TMessage : class
Parameters
Type Name Description
System.Func<IOutboundEnvelope<TMessage>, System.String> topicNameFunction
System.Func<IOutboundEnvelope<TMessage>, System.Int32> partitionFunction
Returns
Type Description
IKafkaProducerEndpointBuilder
Type Parameters
Name Description
TMessage
| Improve this doc View source

ProduceTo<TMessage>(String, Func<IOutboundEnvelope<TMessage>, String[]>, Func<IOutboundEnvelope<TMessage>, Int32>)

Declaration
public IKafkaProducerEndpointBuilder ProduceTo<TMessage>(string topicNameFormatString, Func<IOutboundEnvelope<TMessage>, string[]> topicNameArgumentsFunction, Func<IOutboundEnvelope<TMessage>, int> partitionFunction = null)

    where TMessage : class
Parameters
Type Name Description
System.String topicNameFormatString
System.Func<IOutboundEnvelope<TMessage>, System.String[]> topicNameArgumentsFunction
System.Func<IOutboundEnvelope<TMessage>, System.Int32> partitionFunction
Returns
Type Description
IKafkaProducerEndpointBuilder
Type Parameters
Name Description
TMessage
| Improve this doc View source

UseEndpointNameResolver<TResolver>()

Declaration
public IKafkaProducerEndpointBuilder UseEndpointNameResolver<TResolver>()

    where TResolver : IKafkaProducerEndpointNameResolver
Returns
Type Description
IKafkaProducerEndpointBuilder
Type Parameters
Name Description
TResolver
| Improve this doc View source

WithKafkaKey<TMessage>(Func<IOutboundEnvelope<TMessage>, Object>)

Declaration
public IKafkaProducerEndpointBuilder WithKafkaKey<TMessage>(Func<IOutboundEnvelope<TMessage>, object> valueProvider)

    where TMessage : class
Parameters
Type Name Description
System.Func<IOutboundEnvelope<TMessage>, System.Object> valueProvider
Returns
Type Description
IKafkaProducerEndpointBuilder
Type Parameters
Name Description
TMessage

Implements

Extension Methods