Interface ISerializingProducer<TKey, TValue>

This interface describes the minimum functionality to be provided by a high level (serializing) Kafka producer.

Namespace: Confluent.Kafka

Assembly: cs.temp.dll.dll

Syntax

public interface ISerializingProducer<TKey, TValue>

Type Parameters

Name	Description
TKey
TValue

Properties

KeySerializer

Gets the ISerializer implementation instance used to serialize keys.

Declaration

ISerializer<TKey> KeySerializer { get; }

Property Value

Type	Description
ISerializer<TKey>

Name

Gets the name of the underlying producer instance.

Declaration

string Name { get; }

Property Value

Type	Description
System.String

ValueSerializer

Gets the ISerializer implementation instance used to serialize values.

Declaration

ISerializer<TValue> ValueSerializer { get; }

Property Value

Type	Description
ISerializer<TValue>

Methods

ProduceAsync(String, TKey, TValue)

Refer to ProduceAsync(String, TKey, TValue).

Declaration

Task<Message<TKey, TValue>> ProduceAsync(string topic, TKey key, TValue val)

Parameters

Type	Name	Description
System.String	topic
TKey	key
TValue	val

Returns

Type	Description
Task<Message<TKey, TValue>>

ProduceAsync(String, TKey, TValue, IDeliveryHandler<TKey, TValue>)

Refer to ProduceAsync(String, TKey, TValue, IDeliveryHandler<TKey, TValue>).

Declaration

void ProduceAsync(string topic, TKey key, TValue val, IDeliveryHandler<TKey, TValue> deliveryHandler)

Parameters

Type	Name	Description
System.String	topic
TKey	key
TValue	val
IDeliveryHandler<TKey, TValue>	deliveryHandler

ProduceAsync(String, TKey, TValue, Boolean)

Refer to ProduceAsync(String, TKey, TValue, Boolean).

Declaration

Task<Message<TKey, TValue>> ProduceAsync(string topic, TKey key, TValue val, bool blockIfQueueFull)

Parameters

Type	Name	Description
System.String	topic
TKey	key
TValue	val
System.Boolean	blockIfQueueFull

Returns

Type	Description
Task<Message<TKey, TValue>>

ProduceAsync(String, TKey, TValue, Boolean, IDeliveryHandler<TKey, TValue>)

Refer to ProduceAsync(String, TKey, TValue, Boolean, IDeliveryHandler<TKey, TValue>).

Declaration

void ProduceAsync(string topic, TKey key, TValue val, bool blockIfQueueFull, IDeliveryHandler<TKey, TValue> deliveryHandler)

Parameters

Type	Name	Description
System.String	topic
TKey	key
TValue	val
System.Boolean	blockIfQueueFull
IDeliveryHandler<TKey, TValue>	deliveryHandler

ProduceAsync(String, TKey, TValue, Int32)

Refer to ProduceAsync(String, TKey, TValue, Int32).

Declaration

Task<Message<TKey, TValue>> ProduceAsync(string topic, TKey key, TValue val, int partition)

Parameters

Type	Name	Description
System.String	topic
TKey	key
TValue	val
System.Int32	partition

Returns

Type	Description
Task<Message<TKey, TValue>>

ProduceAsync(String, TKey, TValue, Int32, IDeliveryHandler<TKey, TValue>)

Refer to ProduceAsync(String, TKey, TValue, Int32, IDeliveryHandler<TKey, TValue>).

Declaration

void ProduceAsync(string topic, TKey key, TValue val, int partition, IDeliveryHandler<TKey, TValue> deliveryHandler)

Parameters

Type	Name	Description
System.String	topic
TKey	key
TValue	val
System.Int32	partition
IDeliveryHandler<TKey, TValue>	deliveryHandler

ProduceAsync(String, TKey, TValue, Int32, Boolean)

Refer to ProduceAsync(String, TKey, TValue, Int32, Boolean).

Declaration

Task<Message<TKey, TValue>> ProduceAsync(string topic, TKey key, TValue val, int partition, bool blockIfQueueFull)

Parameters

Type	Name	Description
System.String	topic
TKey	key
TValue	val
System.Int32	partition
System.Boolean	blockIfQueueFull

Returns

Type	Description
Task<Message<TKey, TValue>>

ProduceAsync(String, TKey, TValue, Int32, Boolean, IDeliveryHandler<TKey, TValue>)

Refer to ProduceAsync(String, TKey, TValue, Int32, Boolean, IDeliveryHandler<TKey, TValue>).

Declaration

void ProduceAsync(string topic, TKey key, TValue val, int partition, bool blockIfQueueFull, IDeliveryHandler<TKey, TValue> deliveryHandler)

Parameters

Type	Name	Description
System.String	topic
TKey	key
TValue	val
System.Int32	partition
System.Boolean	blockIfQueueFull
IDeliveryHandler<TKey, TValue>	deliveryHandler