Interface IConfluentProducerBuilder

The Confluent.Kafka.IProducer<TKey, TValue> builder used by the KafkaProducer.

Namespace: Silverback.Messaging.Broker.Kafka

Assembly: Silverback.Integration.Kafka.dll

Syntax

public interface IConfluentProducerBuilder

Methods

Build()

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

Declaration

IProducer<byte[]?, byte[]?> Build()

Returns

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

SetConfig(ProducerConfig)

Sets the producer configuration.

Declaration

IConfluentProducerBuilder SetConfig(ProducerConfig config)

Parameters

Type	Name	Description
ProducerConfig	config	The configuration.

Returns

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

SetLogHandler(Action<IProducer<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

IConfluentProducerBuilder SetLogHandler(Action<IProducer<byte[]?, byte[]?>, LogMessage> logHandler)

Parameters

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

Returns

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

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

Sets the handler to call on statistics events.

Declaration

IConfluentProducerBuilder SetStatisticsHandler(Action<IProducer<byte[]?, byte[]?>, string> statisticsHandler)

Parameters

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

Returns

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