Interface IDeliveryHandler<TKey, TValue>
This interface is implemented by types that handle delivery report callbacks as a result of calls to Confluent.Kafka.Producer<TKey,TValue>.ProduceAsync().
Namespace: Confluent.Kafka
Assembly: cs.temp.dll.dll
Syntax
public interface IDeliveryHandler<TKey, TValue>
Type Parameters
Name | Description |
---|---|
TKey | |
TValue |
Remarks
Methods of this interface will be executed on the poll thread and will block other operations - consider this when implementing.
Properties
MarshalData
Gets whether or not to marshal key and value data from librdkafka when the delivery report is available. Usually this should return true. Return false for a small performance improvement if you don't need this information.
Declaration
bool MarshalData { get; }
Property Value
Type | Description |
---|---|
System.Boolean |
Methods
HandleDeliveryReport(Message<TKey, TValue>)
This method is called when the delivery report is available
Declaration
void HandleDeliveryReport(Message<TKey, TValue> message)
Parameters
Type | Name | Description |
---|---|---|
Message<TKey, TValue> | message | The delivery report. |