Table of Contents

Interface IProducer

Namespace
Org.Apache.Kafka.Clients.Producer
Assembly
MASES.KNet.dll

.NET interface for Producer

public interface IProducer : IJVMBridgeBase, IJVMBridgeDefinition, IDisposable
Inherited Members
IJVMBridgeBase.MonitorEnter()
IJVMBridgeBase.MonitorExit()
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

Methods

AbortTransaction()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/Producer.html#abortTransaction--

void AbortTransaction()

Exceptions

ProducerFencedException

BeginTransaction()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/Producer.html#beginTransaction--

void BeginTransaction()

Exceptions

ProducerFencedException

ClientInstanceId(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/Producer.html#clientInstanceId-java.time.Duration-

Uuid ClientInstanceId(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

Uuid

Uuid

CommitTransaction()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/Producer.html#commitTransaction--

void CommitTransaction()

Exceptions

ProducerFencedException

Flush()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/Producer.html#flush--

void Flush()

InitTransactions()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/Producer.html#initTransactions--

void InitTransactions()

Metrics<T>()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/Producer.html#metrics--

Map<MetricName, T> Metrics<T>() where T : Metric

Returns

Map<MetricName, T>

Map

Type Parameters

T

PartitionsFor(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/Producer.html#partitionsFor-java.lang.String-

List<PartitionInfo> PartitionsFor(String topic)

Parameters

topic String

Returns

List<PartitionInfo>

List

SendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/Producer.html#sendOffsetsToTransaction-java.util.Map-org.apache.kafka.clients.consumer.ConsumerGroupMetadata-

void SendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, ConsumerGroupMetadata groupMetadata)

Parameters

offsets Map<TopicPartition, OffsetAndMetadata>
groupMetadata ConsumerGroupMetadata

Exceptions

ProducerFencedException
Edit this page