Interface IProducer<K, V, TJVMK, TJVMV>
Extends IProducer<K, V> adding less intrusive methods which performs better in high throughput applications
public interface IProducer<K, V, TJVMK, TJVMV> : IProducer<TJVMK, TJVMV>, IProducer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable
Type Parameters
K
Same meaning of IProducer<K, V>
V
Same meaning of IProducer<K, V>
TJVMK
The JVM type of
K
TJVMV
The JVM type of
V
- Inherited Members
-
IJVMBridgeBase.MonitorEnter()IJVMBridgeBase.MonitorExit()IJVMBridgeBase.IsInstanceOf(IJavaType)IJVMBridgeBase.IsInstanceOf<T>()IJVMBridgeBase.RuntimeIsInstanceOf<T>()IJVMBridgeBase.CastTo<TNewClass>()IJVMBridgeBase.CastDirect<TNewClass>()IJVMBridgeBase.DynBridgeInstanceIJVMBridgeBase.BridgeInstanceIJVMBridgeDefinition.BridgeClassNameIJVMBridgeDefinition.IsBridgeInterfaceIJVMBridgeDefinition.IsBridgeAbstractIJVMBridgeDefinition.IsBridgeStaticIJVMBridgeDefinition.IsBridgeCloseableIJVMBridgeDefinition.IsBridgeListener
- Extension Methods
Methods
NewRecord()
Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>
ProducerRecord<K, V, TJVMK, TJVMV> NewRecord()
Returns
- ProducerRecord<K, V, TJVMK, TJVMV>
NewRecord(string, int, DateTime, K, V)
Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>
ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, DateTime timestamp, K key, V value)
Parameters
Returns
- ProducerRecord<K, V, TJVMK, TJVMV>
NewRecord(string, int, DateTime, K, V, Headers)
Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>
ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, DateTime timestamp, K key, V value, Headers headers)
Parameters
Returns
- ProducerRecord<K, V, TJVMK, TJVMV>
NewRecord(string, int, long, K, V)
Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>
ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, long timestamp, K key, V value)
Parameters
Returns
- ProducerRecord<K, V, TJVMK, TJVMV>
NewRecord(string, int, long, K, V, Headers)
Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>
ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, long timestamp, K key, V value, Headers headers)
Parameters
Returns
- ProducerRecord<K, V, TJVMK, TJVMV>
NewRecord(string, int, K, V)
Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>
ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, K key, V value)
Parameters
Returns
- ProducerRecord<K, V, TJVMK, TJVMV>
NewRecord(string, int, K, V, Headers)
Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>
ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, int partition, K key, V value, Headers headers)
Parameters
Returns
- ProducerRecord<K, V, TJVMK, TJVMV>
NewRecord(string, K, V)
Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>
ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, K key, V value)
Parameters
topic
stringkey
Kvalue
V
Returns
- ProducerRecord<K, V, TJVMK, TJVMV>
NewRecord(string, V)
Initialize a new ProducerRecord<K, V, TJVMK, TJVMV>
ProducerRecord<K, V, TJVMK, TJVMV> NewRecord(string topic, V value)
Parameters
topic
stringvalue
V
Returns
- ProducerRecord<K, V, TJVMK, TJVMV>
Produce(ProducerRecord<K, V, TJVMK, TJVMV>, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
Future<RecordMetadata> Produce(ProducerRecord<K, V, TJVMK, TJVMV> record, Callback cb = null)
Parameters
record
ProducerRecord<K, V, TJVMK, TJVMV>cb
Callback
Returns
Produce(ProducerRecord<K, V, TJVMK, TJVMV>, Action<RecordMetadata, JVMBridgeException>)
KNet version of Send(ProducerRecord<K, V>, Callback)
void Produce(ProducerRecord<K, V, TJVMK, TJVMV> record, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
record
ProducerRecord<K, V, TJVMK, TJVMV>action
Action<RecordMetadata, JVMBridgeException>
Produce(string, int, DateTime, K, V, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
Future<RecordMetadata> Produce(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)
Parameters
Returns
Produce(string, int, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)
KNet version of Send(ProducerRecord<K, V>, Callback)
void Produce(string topic, int partition, DateTime timestamp, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
topic
stringpartition
inttimestamp
DateTimekey
Kvalue
Vaction
Action<RecordMetadata, JVMBridgeException>
Produce(string, int, long, K, V, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
Future<RecordMetadata> Produce(string topic, int partition, long timestamp, K key, V value, Callback cb = null)
Parameters
Returns
Produce(string, int, long, K, V, Action<RecordMetadata, JVMBridgeException>)
KNet version of Send(ProducerRecord<K, V>, Callback)
void Produce(string topic, int partition, long timestamp, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
topic
stringpartition
inttimestamp
longkey
Kvalue
Vaction
Action<RecordMetadata, JVMBridgeException>
Produce(string, int, K, V, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
Future<RecordMetadata> Produce(string topic, int partition, K key, V value, Callback cb = null)
Parameters
Returns
Produce(string, int, K, V, Action<RecordMetadata, JVMBridgeException>)
KNet version of Send(ProducerRecord<K, V>, Callback)
void Produce(string topic, int partition, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
topic
stringpartition
intkey
Kvalue
Vaction
Action<RecordMetadata, JVMBridgeException>
Produce(string, K, V, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
Future<RecordMetadata> Produce(string topic, K key, V value, Callback cb = null)
Parameters
Returns
Produce(string, K, V, Action<RecordMetadata, JVMBridgeException>)
KNet version of Send(ProducerRecord<K, V>, Callback)
void Produce(string topic, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
topic
stringkey
Kvalue
Vaction
Action<RecordMetadata, JVMBridgeException>
ProduceAndWait(ProducerRecord<K, V, TJVMK, TJVMV>, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
void ProduceAndWait(ProducerRecord<K, V, TJVMK, TJVMV> record, Callback cb = null)
Parameters
record
ProducerRecord<K, V, TJVMK, TJVMV>cb
Callback
ProduceAndWait(string, int, DateTime, K, V, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
void ProduceAndWait(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)
Parameters
ProduceAndWait(string, int, long, K, V, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
void ProduceAndWait(string topic, int partition, long timestamp, K key, V value, Callback cb = null)
Parameters
ProduceAndWait(string, int, K, V, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
void ProduceAndWait(string topic, int partition, K key, V value, Callback cb = null)
Parameters
ProduceAndWait(string, K, V, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
void ProduceAndWait(string topic, K key, V value, Callback cb = null)
Parameters
ProduceAsync(ProducerRecord<K, V, TJVMK, TJVMV>, Action<RecordMetadata, JVMBridgeException>)
KNet async version of Send(ProducerRecord<K, V>, Callback)
Task ProduceAsync(ProducerRecord<K, V, TJVMK, TJVMV> record, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
record
ProducerRecord<K, V, TJVMK, TJVMV>action
Action<RecordMetadata, JVMBridgeException>
Returns
ProduceAsync(string, int, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)
KNet async version of Send(ProducerRecord<K, V>, Callback)
Task ProduceAsync(string topic, int partition, DateTime timestamp, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
topic
stringpartition
inttimestamp
DateTimekey
Kvalue
Vaction
Action<RecordMetadata, JVMBridgeException>
Returns
ProduceAsync(string, int, long, K, V, Action<RecordMetadata, JVMBridgeException>)
KNet async version of Send(ProducerRecord<K, V>, Callback)
Task ProduceAsync(string topic, int partition, long timestamp, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
topic
stringpartition
inttimestamp
longkey
Kvalue
Vaction
Action<RecordMetadata, JVMBridgeException>
Returns
ProduceAsync(string, int, K, V, Action<RecordMetadata, JVMBridgeException>)
KNet async version of Send(ProducerRecord<K, V>, Callback)
Task ProduceAsync(string topic, int partition, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
topic
stringpartition
intkey
Kvalue
Vaction
Action<RecordMetadata, JVMBridgeException>
Returns
ProduceAsync(string, K, V, Action<RecordMetadata, JVMBridgeException>)
KNet async version of Send(ProducerRecord<K, V>, Callback)
Task ProduceAsync(string topic, K key, V value, Action<RecordMetadata, JVMBridgeException> action = null)
Parameters
topic
stringkey
Kvalue
Vaction
Action<RecordMetadata, JVMBridgeException>
Returns
Send(ProducerRecord<K, V, TJVMK, TJVMV>)
KNet version of Send(ProducerRecord<K, V>)
Future<RecordMetadata> Send(ProducerRecord<K, V, TJVMK, TJVMV> record)
Parameters
record
ProducerRecord<K, V, TJVMK, TJVMV>
Returns
Send(ProducerRecord<K, V, TJVMK, TJVMV>, Callback)
KNet version of Send(ProducerRecord<K, V>, Callback)
Future<RecordMetadata> Send(ProducerRecord<K, V, TJVMK, TJVMV> record, Callback callback)
Parameters
record
ProducerRecord<K, V, TJVMK, TJVMV>callback
Callback
Returns
Send(string, int, long, K, V)
KNet version of Send(ProducerRecord<K, V>)
void Send(string topic, int partition, long timestamp, K key, V value)
Parameters
Send(string, int, long, K, V, Headers)
KNet version of Send(ProducerRecord<K, V>)
void Send(string topic, int partition, long timestamp, K key, V value, Headers headers)
Parameters
Send(string, int, K, V)
KNet version of Send(ProducerRecord<K, V>)
void Send(string topic, int partition, K key, V value)
Parameters
Send(string, int, K, V, Headers)
KNet version of Send(ProducerRecord<K, V>)
void Send(string topic, int partition, K key, V value, Headers headers)
Parameters
Send(string, K, V)
KNet version of Send(ProducerRecord<K, V>)
void Send(string topic, K key, V value)
Parameters
topic
stringkey
Kvalue
V
Send(string, V)
KNet version of Send(ProducerRecord<K, V>)
void Send(string topic, V value)
Parameters
topic
stringvalue
V
SetCallback(Callback)
Set Callback into instance of IProducer<K, V>
void SetCallback(Callback callback)