Class DependentProducerBuilder<TKey, TValue>
A builder class for IProducer<TKey, TValue> instance implementations that leverage an existing client handle.
[API-SUBJECT-TO-CHANGE] - This class may be removed in the future in favor of an improved API for this functionality.
Inheritance
DependentProducerBuilder<TKey, TValue>
Assembly: Confluent.Kafka.dll
Syntax
public class DependentProducerBuilder<TKey, TValue>
Type Parameters
| Name | Description |
|---|
| TKey | |
| TValue | |
Constructors
DependentProducerBuilder(Handle)
An underlying librdkafka client handle that the Producer will use to make broker requests. The handle must be from another Producer instance (not Consumer or AdminClient).
Declaration
public DependentProducerBuilder(Handle handle)
Parameters
| Type | Name | Description |
|---|
| Handle | handle | |
Properties
AsyncKeySerializer
The configured async key serializer.
Declaration
public IAsyncSerializer<TKey> AsyncKeySerializer { get; set; }
Property Value
AsyncValueSerializer
The configured async value serializer.
Declaration
public IAsyncSerializer<TValue> AsyncValueSerializer { get; set; }
Property Value
Handle
The configured client handle.
Declaration
public Handle Handle { get; set; }
Property Value
KeySerializer
The configured key serializer.
Declaration
public ISerializer<TKey> KeySerializer { get; set; }
Property Value
ValueSerializer
The configured value serializer.
Declaration
public ISerializer<TValue> ValueSerializer { get; set; }
Property Value
Methods
Build()
Build a new IProducer implementation instance.
Declaration
public virtual IProducer<TKey, TValue> Build()
Returns
SetKeySerializer(IAsyncSerializer<TKey>)
The async serializer to use to serialize keys.
Declaration
public DependentProducerBuilder<TKey, TValue> SetKeySerializer(IAsyncSerializer<TKey> serializer)
Parameters
Returns
SetKeySerializer(ISerializer<TKey>)
The serializer to use to serialize keys.
Declaration
public DependentProducerBuilder<TKey, TValue> SetKeySerializer(ISerializer<TKey> serializer)
Parameters
Returns
SetValueSerializer(IAsyncSerializer<TValue>)
The async serializer to use to serialize values.
Declaration
public DependentProducerBuilder<TKey, TValue> SetValueSerializer(IAsyncSerializer<TValue> serializer)
Parameters
Returns
SetValueSerializer(ISerializer<TValue>)
The serializer to use to serialize values.
Declaration
public DependentProducerBuilder<TKey, TValue> SetValueSerializer(ISerializer<TValue> serializer)
Parameters
Returns