Interface IProducer<K, V>

Namespace

Org.Apache.Kafka.Clients.Producer

Assembly

MASES.KNet.dll

.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/producer/Producer.html

public interface IProducer<K, V> : IProducer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable

Type Parameters

K

V

Inherited Members

IProducer.InitTransactions()

IProducer.BeginTransaction()

IProducer.SendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata)

IProducer.CommitTransaction()

IProducer.AbortTransaction()

IProducer.Flush()

IProducer.PartitionsFor(String)

IProducer.Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()

IProducer.ClientInstanceId(Duration)

IJVMBridgeBase.MonitorEnter()

IJVMBridgeBase.MonitorExit()

IJVMBridgeBase.IsInstanceOf(string)

IJVMBridgeBase.IsInstanceOf(IJavaType)

IJVMBridgeBase.IsInstanceOf<T>()

IJVMBridgeBase.RuntimeIsInstanceOf<T>()

IJVMBridgeBase.CastTo<TNewClass>()

IJVMBridgeBase.CastDirect<TNewClass>()

IJVMBridgeBase.DynBridgeInstance

IJVMBridgeBase.BridgeInstance

IJVMBridgeDefinition.BridgeClassName

IJVMBridgeDefinition.IsBridgeInterface

IJVMBridgeDefinition.IsBridgeAbstract

IJVMBridgeDefinition.IsBridgeStatic

IJVMBridgeDefinition.IsBridgeCloseable

IJVMBridgeDefinition.IsBridgeListener

IDisposable.Dispose()

ICloseable.Close()

Extension Methods

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, ProducerRecord<K, V>, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, int, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, int, long, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, int, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.ProduceAsync<K, V>(IProducer<K, V>, string, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, ProducerRecord<K, V>, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, ProducerRecord<K, V>, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, DateTime, K, V, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, long, K, V, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, long, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, K, V, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, int, K, V, Action<RecordMetadata, JVMBridgeException>)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, K, V, Callback)

KafkaProducerExtensions.Produce<K, V>(IProducer<K, V>, string, K, V, Action<RecordMetadata, JVMBridgeException>)

Methods

Send(ProducerRecord<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/producer/Producer.html#send(org.apache.kafka.clients.producer.ProducerRecord)

Future<RecordMetadata> Send(ProducerRecord<K, V> record)

Parameters

record ProducerRecord<K, V>

Returns

Future<RecordMetadata>

Future

Send(ProducerRecord<K, V>, Callback)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/producer/Producer.html#send(org.apache.kafka.clients.producer.ProducerRecord,org.apache.kafka.clients.producer.Callback)

Future<RecordMetadata> Send(ProducerRecord<K, V> record, Callback callback)

Parameters

record ProducerRecord<K, V>

callback Callback

Returns

Future<RecordMetadata>

Future