Class Producer<K, V>
public class Producer<K, V> : Closeable, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IJVMBridgeBaseStatic, IProducer<K, V>, IProducer, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseableType Parameters
KV
- Inheritance
-
Producer<K, V>
- Implements
-
IProducer<K, V>
- Derived
- Extension Methods
Constructors
Producer(IJVMBridgeBaseInitializer)
Initializer used internally by JCOBridge. Do not use directly.
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public Producer(IJVMBridgeBaseInitializer initializer)Parameters
initializerIJVMBridgeBaseInitializer
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
true if the BridgeClassName implements java.lang.AutoCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
public override bool IsBridgeStatic { get; }Property Value
Methods
AbortTransaction()
public void AbortTransaction()Exceptions
BeginTransaction()
public void BeginTransaction()Exceptions
ClientInstanceId(Duration)
public Uuid ClientInstanceId(Duration arg0)Parameters
Returns
Close()
public void Close()Close(Duration)
public void Close(Duration arg0)Parameters
CommitTransaction()
public void CommitTransaction()Exceptions
Flush()
public void Flush()InitTransactions()
public void InitTransactions()Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()
public Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric> Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>() where ReturnExtendsOrg_Apache_Kafka_Common_Metric : MetricReturns
- Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric>
Type Parameters
ReturnExtendsOrg_Apache_Kafka_Common_Metric
PartitionsFor(String)
public List<PartitionInfo> PartitionsFor(String arg0)Parameters
Returns
RegisterMetricForSubscription(KafkaMetric)
public void RegisterMetricForSubscription(KafkaMetric arg0)Parameters
arg0KafkaMetric
Send(ProducerRecord<K, V>)
public Future<RecordMetadata> Send(ProducerRecord<K, V> arg0)Parameters
arg0ProducerRecord<K, V>
Returns
Send(ProducerRecord<K, V>, Callback)
public Future<RecordMetadata> Send(ProducerRecord<K, V> arg0, Callback arg1)Parameters
arg0ProducerRecord<K, V>arg1Callback
Returns
SendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata)
public void SendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> arg0, ConsumerGroupMetadata arg1)Parameters
Exceptions
UnregisterMetricFromSubscription(KafkaMetric)
public void UnregisterMetricFromSubscription(KafkaMetric arg0)Parameters
arg0KafkaMetric
Operators
implicit operator Producer(Producer<K, V>)
Converter from Producer<K, V> to Producer
public static implicit operator Producer(Producer<K, V> t)Parameters
tProducer<K, V>