Class KafkaBroker

An IBroker implementation for Apache Kafka.

Inheritance
System.Object
Broker<KafkaProducerEndpoint, KafkaConsumerEndpoint>
KafkaBroker
Implements
System.IDisposable
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
Assembly: Silverback.Integration.Kafka.dll
Syntax
public class KafkaBroker : Broker<KafkaProducerEndpoint, KafkaConsumerEndpoint>, IBroker, IDisposable

Constructors

| Improve this doc View source

KafkaBroker(IServiceProvider)

Initializes a new instance of the KafkaBroker class.

Declaration
public KafkaBroker(IServiceProvider serviceProvider)
Parameters
Type Name Description
System.IServiceProvider serviceProvider

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

Methods

| Improve this doc View source

Dispose(Boolean)

Declaration
protected override void Dispose(bool disposing)
Parameters
Type Name Description
System.Boolean disposing
Overrides
Silverback.Messaging.Broker.Broker<Silverback.Messaging.KafkaProducerEndpoint, Silverback.Messaging.KafkaConsumerEndpoint>.Dispose(System.Boolean)
| Improve this doc View source

GetProducer(IProducerEndpoint)

Declaration
public override IProducer GetProducer(IProducerEndpoint endpoint)
Parameters
Type Name Description
IProducerEndpoint endpoint
Returns
Type Description
IProducer
Overrides
Silverback.Messaging.Broker.Broker<Silverback.Messaging.KafkaProducerEndpoint, Silverback.Messaging.KafkaConsumerEndpoint>.GetProducer(Silverback.Messaging.IProducerEndpoint)
| Improve this doc View source

GetProducer(String)

Declaration
public override IProducer GetProducer(string endpointName)
Parameters
Type Name Description
System.String endpointName
Returns
Type Description
IProducer
Overrides
Silverback.Messaging.Broker.Broker<Silverback.Messaging.KafkaProducerEndpoint, Silverback.Messaging.KafkaConsumerEndpoint>.GetProducer(System.String)
| Improve this doc View source

GetTransactionalProducer(IProducerEndpoint)

Returns a KafkaTransactionalProducer to be used to produce to the specified endpoint using a transaction.

Declaration
public KafkaTransactionalProducer GetTransactionalProducer(IProducerEndpoint endpoint)
Parameters
Type Name Description
IProducerEndpoint endpoint

The target endpoint.
Returns
Type Description
KafkaTransactionalProducer

The IProducer for the specified endpoint.
| Improve this doc View source

GetTransactionalProducer(String)

Returns an existing IProducer to be used to produce to the specified endpoint.

Declaration
public KafkaTransactionalProducer GetTransactionalProducer(string endpointName)
Parameters
Type Name Description
System.String endpointName

The target endpoint name (or friendly name).
Returns
Type Description
KafkaTransactionalProducer

The IProducer for the specified endpoint.
| Improve this doc View source

InstantiateConsumer(KafkaConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)

Declaration
protected override IConsumer InstantiateConsumer(KafkaConsumerEndpoint endpoint, IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider, IServiceProvider serviceProvider)
Parameters
Type Name Description
KafkaConsumerEndpoint endpoint
IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider
System.IServiceProvider serviceProvider
Returns
Type Description
IConsumer
Overrides
Silverback.Messaging.Broker.Broker<Silverback.Messaging.KafkaProducerEndpoint, Silverback.Messaging.KafkaConsumerEndpoint>.InstantiateConsumer(Silverback.Messaging.KafkaConsumerEndpoint, Silverback.Messaging.Broker.Behaviors.IBrokerBehaviorsProvider<Silverback.Messaging.Broker.Behaviors.IConsumerBehavior>, System.IServiceProvider)
| Improve this doc View source

InstantiateProducer(KafkaProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider)

Declaration
protected override IProducer InstantiateProducer(KafkaProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider)
Parameters
Type Name Description
KafkaProducerEndpoint endpoint
IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider
System.IServiceProvider serviceProvider
Returns
Type Description
IProducer
Overrides
Silverback.Messaging.Broker.Broker<Silverback.Messaging.KafkaProducerEndpoint, Silverback.Messaging.KafkaConsumerEndpoint>.InstantiateProducer(Silverback.Messaging.KafkaProducerEndpoint, Silverback.Messaging.Broker.Behaviors.IBrokerBehaviorsProvider<Silverback.Messaging.Broker.Behaviors.IProducerBehavior>, System.IServiceProvider)

Implements

System.IDisposable