diff --git a/docs/api/MASES.KNet.Consumer.KNetConsumer-2.html b/docs/api/MASES.KNet.Consumer.KNetConsumer-2.html
index 7f2d0de2bf..db554852d9 100644
--- a/docs/api/MASES.KNet.Consumer.KNetConsumer-2.html
+++ b/docs/api/MASES.KNet.Consumer.KNetConsumer-2.html
@@ -577,7 +577,7 @@
Constructors
Improve this Doc
- View Source
+ View Source
KNetConsumer(Properties, IKNetDeserializer<K>, IKNetDeserializer<V>, Boolean)
@@ -629,7 +629,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
KNetConsumer(Properties, Boolean)
@@ -671,7 +671,7 @@ Properties
Improve this Doc
- View Source
+ View Source
BridgeClassName
@@ -704,7 +704,7 @@ Overrides
Improve this Doc
- View Source
+ View Source
IsCompleting
@@ -735,7 +735,7 @@ Property Value
Improve this Doc
- View Source
+ View Source
IsEmpty
@@ -766,7 +766,7 @@ Property Value
Improve this Doc
- View Source
+ View Source
WaitingMessages
@@ -799,7 +799,7 @@ Methods
Improve this Doc
- View Source
+ View Source
Consume(Int64, Action<KNetConsumerRecord<K, V>>)
@@ -839,7 +839,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
ConsumeAsync(Int64)
@@ -873,7 +873,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Dispose()
@@ -890,7 +890,7 @@ Overrides
Improve this Doc
- View Source
+ View Source
Finalize()
@@ -906,7 +906,7 @@ Declaration
Improve this Doc
- View Source
+ View Source
Poll(Duration)
@@ -956,7 +956,7 @@ Returns
Improve this Doc
- View Source
+ View Source
Poll(Int64)
@@ -1006,7 +1006,7 @@ Returns
Improve this Doc
- View Source
+ View Source
SetCallback(Action<KNetConsumerRecord<K, V>>)
diff --git a/docs/api/MASES.KNet.KNetCompactedReplicator-2.html b/docs/api/MASES.KNet.KNetCompactedReplicator-2.html
index 638d5f489c..551bb7ddb3 100644
--- a/docs/api/MASES.KNet.KNetCompactedReplicator-2.html
+++ b/docs/api/MASES.KNet.KNetCompactedReplicator-2.html
@@ -302,7 +302,7 @@ Property Value
Improve this Doc
- View Source
+ View Source
Count
@@ -350,7 +350,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
IsReadOnly
@@ -381,7 +381,7 @@ Property Value
Improve this Doc
- View Source
+ View Source
Item[TKey]
@@ -462,7 +462,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
Keys
@@ -727,7 +727,7 @@ Property Value
Improve this Doc
- View Source
+ View Source
Values
@@ -808,7 +808,7 @@ Methods
Improve this Doc
- View Source
+ View Source
Add(TKey, TValue)
@@ -869,7 +869,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
Add(KeyValuePair<TKey, TValue>)
@@ -924,7 +924,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
Clear()
@@ -956,7 +956,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
Contains(KeyValuePair<TKey, TValue>)
@@ -1027,7 +1027,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
ContainsKey(TKey)
@@ -1098,7 +1098,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
CopyTo(KeyValuePair<TKey, TValue>[], Int32)
@@ -1172,7 +1172,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
Dispose()
@@ -1188,7 +1188,7 @@ Declaration
Improve this Doc
- View Source
+ View Source
Flush()
@@ -1204,7 +1204,7 @@ Declaration
Improve this Doc
- View Source
+ View Source
GetEnumerator()
@@ -1252,7 +1252,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
Remove(TKey)
@@ -1323,7 +1323,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
Remove(KeyValuePair<TKey, TValue>)
@@ -1394,7 +1394,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
Start()
@@ -1426,7 +1426,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
TryGetValue(TKey, out TValue)
@@ -1504,7 +1504,7 @@ Exceptions
Improve this Doc
- View Source
+ View Source
WaitForStateAssignment(Int32)
@@ -1634,7 +1634,7 @@ Explicit Interface Implementations
Improve this Doc
- View Source
+ View Source
IEnumerable.GetEnumerator()
diff --git a/docs/api/MASES.KNet.Producer.IKNetProducer-2.html b/docs/api/MASES.KNet.Producer.IKNetProducer-2.html
index aaec394abb..e99d1b53ef 100644
--- a/docs/api/MASES.KNet.Producer.IKNetProducer-2.html
+++ b/docs/api/MASES.KNet.Producer.IKNetProducer-2.html
@@ -188,7 +188,7 @@ Methods
Improve this Doc
- View Source
+ View Source
Produce(KNetProducerRecord<K, V>, Callback)
@@ -197,7 +197,7 @@
Declaration
-
void Produce(KNetProducerRecord<K, V> record, Callback cb = null)
+
Future<RecordMetadata> Produce(KNetProducerRecord<K, V> record, Callback cb = null)
Parameters
@@ -221,6 +221,21 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
@@ -273,7 +288,7 @@
Declaration
-
void Produce(string topic, K key, V value, Callback cb = null)
+
Future<RecordMetadata> Produce(string topic, K key, V value, Callback cb = null)
Parameters
@@ -307,6 +322,21 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
@@ -360,7 +390,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Produce(String, Int32, K, V, Callback)
@@ -369,7 +399,7 @@
Declaration
-
void Produce(string topic, int partition, K key, V value, Callback cb = null)
+
Future<RecordMetadata> Produce(string topic, int partition, K key, V value, Callback cb = null)
Parameters
@@ -408,6 +438,21 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
@@ -466,7 +511,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Produce(String, Int32, DateTime, K, V, Callback)
@@ -475,7 +520,7 @@
Declaration
-
void Produce(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)
+
Future<RecordMetadata> Produce(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)
Parameters
@@ -519,6 +564,21 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
@@ -582,7 +642,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Produce(String, Int32, Int64, K, V, Callback)
@@ -591,7 +651,7 @@
Declaration
-
void Produce(string topic, int partition, long timestamp, K key, V value, Callback cb = null)
+
Future<RecordMetadata> Produce(string topic, int partition, long timestamp, K key, V value, Callback cb = null)
Parameters
@@ -635,6 +695,21 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
@@ -695,11 +770,266 @@ Parameters
|
- Improve this Doc
+ Improve this Doc
View Source
+
+ ProduceAndWait(KNetProducerRecord<K, V>, Callback)
+
+
+ Declaration
+
+
void ProduceAndWait(KNetProducerRecord<K, V> record, Callback cb = null)
+
+ Parameters
+
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ ProduceAndWait(String, K, V, Callback)
+
+
+ Declaration
+
+
void ProduceAndWait(string topic, K key, V value, Callback cb = null)
+
+ Parameters
+
+
+
+ Type |
+ Name |
+ Description |
+
+
+
+
+ String |
+ topic |
+ |
+
+
+ K |
+ key |
+ |
+
+
+ V |
+ value |
+ |
+
+
+ Callback |
+ cb |
+ |
+
+
+
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ ProduceAndWait(String, Int32, K, V, Callback)
+
+
+ Declaration
+
+
void ProduceAndWait(string topic, int partition, K key, V value, Callback cb = null)
+
+ Parameters
+
+
+
+ Type |
+ Name |
+ Description |
+
+
+
+
+ String |
+ topic |
+ |
+
+
+ Int32 |
+ partition |
+ |
+
+
+ K |
+ key |
+ |
+
+
+ V |
+ value |
+ |
+
+
+ Callback |
+ cb |
+ |
+
+
+
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ ProduceAndWait(String, Int32, DateTime, K, V, Callback)
+
+
+ Declaration
+
+
void ProduceAndWait(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)
+
+ Parameters
+
+
+
+ Type |
+ Name |
+ Description |
+
+
+
+
+ String |
+ topic |
+ |
+
+
+ Int32 |
+ partition |
+ |
+
+
+ DateTime |
+ timestamp |
+ |
+
+
+ K |
+ key |
+ |
+
+
+ V |
+ value |
+ |
+
+
+ Callback |
+ cb |
+ |
+
+
+
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ ProduceAndWait(String, Int32, Int64, K, V, Callback)
+
+
+ Declaration
+
+
void ProduceAndWait(string topic, int partition, long timestamp, K key, V value, Callback cb = null)
+
+ Parameters
+
+
+
+ Type |
+ Name |
+ Description |
+
+
+
+
+ String |
+ topic |
+ |
+
+
+ Int32 |
+ partition |
+ |
+
+
+ Int64 |
+ timestamp |
+ |
+
+
+ K |
+ key |
+ |
+
+
+ V |
+ value |
+ |
+
+
+ Callback |
+ cb |
+ |
+
+
+
+
+ |
+ Improve this Doc
+
+
+ View Source
+
KNet async version of Send(ProducerRecord<K, V>, Callback)
@@ -751,7 +1081,7 @@
Returns
Improve this Doc
- View Source
+ View Source
@@ -814,7 +1144,7 @@
Returns
Improve this Doc
- View Source
+ View Source
@@ -882,7 +1212,7 @@
Returns
Improve this Doc
- View Source
+ View Source
@@ -955,7 +1285,7 @@
Returns
Improve this Doc
- View Source
+ View Source
diff --git a/docs/api/MASES.KNet.Producer.KNetProducer-2.html b/docs/api/MASES.KNet.Producer.KNetProducer-2.html
index 66b25e5c21..93cb04a78a 100644
--- a/docs/api/MASES.KNet.Producer.KNetProducer-2.html
+++ b/docs/api/MASES.KNet.Producer.KNetProducer-2.html
@@ -484,7 +484,7 @@
Declaration
-
public void Produce(KNetProducerRecord<K, V> record, Callback cb = null)
+
public Future<RecordMetadata> Produce(KNetProducerRecord<K, V> record, Callback cb = null)
Parameters
@@ -650,12 +650,27 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
- View Source
+ View Source
Produce(KNetProducerRecord<K, V>, Action<RecordMetadata, JVMBridgeException>)
@@ -693,7 +708,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Produce(String, K, V, Callback)
@@ -702,7 +717,7 @@
Declaration
-
public void Produce(string topic, K key, V value, Callback cb = null)
+
public Future<RecordMetadata> Produce(string topic, K key, V value, Callback cb = null)
Parameters
@@ -736,12 +751,27 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
- View Source
+ View Source
Produce(String, K, V, Action<RecordMetadata, JVMBridgeException>)
@@ -789,7 +819,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Produce(String, Int32, K, V, Callback)
@@ -798,7 +828,7 @@
Declaration
-
public void Produce(string topic, int partition, K key, V value, Callback cb = null)
+
public Future<RecordMetadata> Produce(string topic, int partition, K key, V value, Callback cb = null)
Parameters
@@ -837,12 +867,27 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
- View Source
+ View Source
Produce(String, Int32, K, V, Action<RecordMetadata, JVMBridgeException>)
@@ -895,7 +940,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Produce(String, Int32, DateTime, K, V, Callback)
@@ -904,7 +949,7 @@
Declaration
-
public void Produce(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)
+
public Future<RecordMetadata> Produce(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)
Parameters
@@ -948,12 +993,27 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
- View Source
+ View Source
Produce(String, Int32, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)
@@ -1011,7 +1071,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Produce(String, Int32, Int64, K, V, Callback)
@@ -1020,7 +1080,7 @@
Declaration
-
public void Produce(string topic, int partition, long timestamp, K key, V value, Callback cb = null)
+
public Future<RecordMetadata> Produce(string topic, int partition, long timestamp, K key, V value, Callback cb = null)
Parameters
@@ -1064,12 +1124,27 @@ Parameters
+ Returns
+
+
+
+ Type |
+ Description |
+
+
+
+
+ Java.Util.Concurrent.Future<RecordMetadata> |
+ |
+
+
+
|
Improve this Doc
- View Source
+ View Source
Produce(String, Int32, Int64, K, V, Action<RecordMetadata, JVMBridgeException>)
@@ -1122,12 +1197,267 @@ Parameters
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ ProduceAndWait(KNetProducerRecord<K, V>, Callback)
+
+
+ Declaration
+
+
public void ProduceAndWait(KNetProducerRecord<K, V> record, Callback cb = null)
+
+ Parameters
+
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ ProduceAndWait(String, K, V, Callback)
+
+
+ Declaration
+
+
public void ProduceAndWait(string topic, K key, V value, Callback cb = null)
+
+ Parameters
+
+
+
+ Type |
+ Name |
+ Description |
+
+
+
+
+ String |
+ topic |
+ |
+
+
+ K |
+ key |
+ |
+
+
+ V |
+ value |
+ |
+
+
+ Callback |
+ cb |
+ |
+
+
+
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ ProduceAndWait(String, Int32, K, V, Callback)
+
+
+ Declaration
+
+
public void ProduceAndWait(string topic, int partition, K key, V value, Callback cb = null)
+
+ Parameters
+
+
+
+ Type |
+ Name |
+ Description |
+
+
+
+
+ String |
+ topic |
+ |
+
+
+ Int32 |
+ partition |
+ |
+
+
+ K |
+ key |
+ |
+
+
+ V |
+ value |
+ |
+
+
+ Callback |
+ cb |
+ |
+
+
+
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ ProduceAndWait(String, Int32, DateTime, K, V, Callback)
+
+
+ Declaration
+
+
public void ProduceAndWait(string topic, int partition, DateTime timestamp, K key, V value, Callback cb = null)
+
+ Parameters
+
+
+
+ Type |
+ Name |
+ Description |
+
+
+
+
+ String |
+ topic |
+ |
+
+
+ Int32 |
+ partition |
+ |
+
+
+ DateTime |
+ timestamp |
+ |
+
+
+ K |
+ key |
+ |
+
+
+ V |
+ value |
+ |
+
+
+ Callback |
+ cb |
+ |
+
+
+
+
+ |
+ Improve this Doc
+
+
+ View Source
+
+
+ ProduceAndWait(String, Int32, Int64, K, V, Callback)
+
+
+ Declaration
+
+
public void ProduceAndWait(string topic, int partition, long timestamp, K key, V value, Callback cb = null)
+
+ Parameters
+
+
+
+ Type |
+ Name |
+ Description |
+
+
+
+
+ String |
+ topic |
+ |
+
+
+ Int32 |
+ partition |
+ |
+
+
+ Int64 |
+ timestamp |
+ |
+
+
+ K |
+ key |
+ |
+
+
+ V |
+ value |
+ |
+
+
+ Callback |
+ cb |
+ |
+
+
+
|
Improve this Doc
- View Source
+ View Source
ProduceAsync(KNetProducerRecord<K, V>, Action<RecordMetadata, JVMBridgeException>)
@@ -1180,7 +1510,7 @@ Returns
Improve this Doc
- View Source
+ View Source
ProduceAsync(String, K, V, Action<RecordMetadata, JVMBridgeException>)
@@ -1243,7 +1573,7 @@ Returns
Improve this Doc
- View Source
+ View Source
ProduceAsync(String, Int32, K, V, Action<RecordMetadata, JVMBridgeException>)
@@ -1311,7 +1641,7 @@ Returns
Improve this Doc
- View Source
+ View Source
ProduceAsync(String, Int32, DateTime, K, V, Action<RecordMetadata, JVMBridgeException>)
@@ -1384,7 +1714,7 @@ Returns
Improve this Doc
- View Source
+ View Source
ProduceAsync(String, Int32, Int64, K, V, Action<RecordMetadata, JVMBridgeException>)
@@ -1457,7 +1787,7 @@ Returns
Improve this Doc
- View Source
+ View Source
Send(KNetProducerRecord<K, V>)
@@ -1505,7 +1835,7 @@ Returns
Improve this Doc
- View Source
+ View Source
Send(KNetProducerRecord<K, V>, Callback)
@@ -1558,7 +1888,7 @@ Returns
Improve this Doc
- View Source
+ View Source
Send(String, K, V)
@@ -1601,7 +1931,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Send(String, V)
@@ -1639,7 +1969,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Send(String, Int32, K, V)
@@ -1687,7 +2017,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
@@ -1740,7 +2070,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
Send(String, Int32, Int64, K, V)
@@ -1793,7 +2123,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
@@ -1851,7 +2181,7 @@ Parameters
Improve this Doc
- View Source
+ View Source
SetCallback(Callback)
@@ -1971,7 +2301,7 @@ Extension Methods
Improve this Doc
- View Source
+ View Source
diff --git a/docs/manifest.json b/docs/manifest.json
index 33b9000d16..9209956ee2 100644
--- a/docs/manifest.json
+++ b/docs/manifest.json
@@ -1197,7 +1197,7 @@
"output": {
".html": {
"relative_path": "api/MASES.KNet.Consumer.KNetConsumer-2.html",
- "hash": "hJIUwvuQGZnTS/5L1Kyc022M4uINTvlIWBYl0XhxfnQ="
+ "hash": "+XGx6nuazFHSCkHggeEQ0JVa3lfcdA1XFzyn097A1nU="
}
},
"is_incremental": false,
@@ -1365,7 +1365,7 @@
"output": {
".html": {
"relative_path": "api/MASES.KNet.KNetCompactedReplicator-2.html",
- "hash": "90BQbrSFJ4ldJw55Mpvvdu3Rin5MClNpLZK4DxPER4Y="
+ "hash": "D6lOLNkk+S8etXCUjCcFCqTXtgSeolPeiRsPLhAW2fw="
}
},
"is_incremental": false,
@@ -1389,7 +1389,7 @@
"output": {
".html": {
"relative_path": "api/MASES.KNet.Producer.IKNetProducer-2.html",
- "hash": "Oy07YUHquzUYRmNpffrTtM5YJIek+yJdr/1e/FcMst0="
+ "hash": "BE2myaQ4Vn56wv4vJZOQXqyz5B9hCkapILMK1Twf8Mo="
}
},
"is_incremental": false,
@@ -1401,7 +1401,7 @@
"output": {
".html": {
"relative_path": "api/MASES.KNet.Producer.KNetProducer-2.html",
- "hash": "uAGSJfNjiI653F2m7yUrtcYizzOZOgLyEDzPzy9Gdh0="
+ "hash": "PKMIe1oA2/SpgGb5O9BBUxI4oRrpQnl1dJc39spcYlE="
}
},
"is_incremental": false,
diff --git a/docs/xrefmap.yml b/docs/xrefmap.yml
index 7df4b6f711..ec90c33e87 100644
--- a/docs/xrefmap.yml
+++ b/docs/xrefmap.yml
@@ -17708,6 +17708,56 @@ references:
fullName.vb: MASES.KNet.Producer.IKNetProducer(Of K, V).Produce
nameWithType: IKNetProducer.Produce
nameWithType.vb: IKNetProducer(Of K, V).Produce
+- uid: MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(MASES.KNet.Producer.KNetProducerRecord{`0,`1},Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(KNetProducerRecord, Callback)
+ href: api/MASES.KNet.Producer.IKNetProducer-2.html#MASES_KNet_Producer_IKNetProducer_2_ProduceAndWait_MASES_KNet_Producer_KNetProducerRecord__0__1__Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(MASES.KNet.Producer.KNetProducerRecord{`0,`1},Org.Apache.Kafka.Clients.Producer.Callback)
+ name.vb: ProduceAndWait(KNetProducerRecord(Of K, V), Callback)
+ fullName: MASES.KNet.Producer.IKNetProducer.ProduceAndWait(MASES.KNet.Producer.KNetProducerRecord, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.IKNetProducer(Of K, V).ProduceAndWait(MASES.KNet.Producer.KNetProducerRecord(Of K, V), Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: IKNetProducer.ProduceAndWait(KNetProducerRecord, Callback)
+ nameWithType.vb: IKNetProducer(Of K, V).ProduceAndWait(KNetProducerRecord(Of K, V), Callback)
+- uid: MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(System.String,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(String, K, V, Callback)
+ href: api/MASES.KNet.Producer.IKNetProducer-2.html#MASES_KNet_Producer_IKNetProducer_2_ProduceAndWait_System_String__0__1_Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(System.String,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName: MASES.KNet.Producer.IKNetProducer.ProduceAndWait(System.String, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.IKNetProducer(Of K, V).ProduceAndWait(System.String, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: IKNetProducer.ProduceAndWait(String, K, V, Callback)
+ nameWithType.vb: IKNetProducer(Of K, V).ProduceAndWait(String, K, V, Callback)
+- uid: MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(System.String,System.Int32,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(String, Int32, K, V, Callback)
+ href: api/MASES.KNet.Producer.IKNetProducer-2.html#MASES_KNet_Producer_IKNetProducer_2_ProduceAndWait_System_String_System_Int32__0__1_Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(System.String,System.Int32,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName: MASES.KNet.Producer.IKNetProducer.ProduceAndWait(System.String, System.Int32, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.IKNetProducer(Of K, V).ProduceAndWait(System.String, System.Int32, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: IKNetProducer.ProduceAndWait(String, Int32, K, V, Callback)
+ nameWithType.vb: IKNetProducer(Of K, V).ProduceAndWait(String, Int32, K, V, Callback)
+- uid: MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(System.String,System.Int32,System.DateTime,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(String, Int32, DateTime, K, V, Callback)
+ href: api/MASES.KNet.Producer.IKNetProducer-2.html#MASES_KNet_Producer_IKNetProducer_2_ProduceAndWait_System_String_System_Int32_System_DateTime__0__1_Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(System.String,System.Int32,System.DateTime,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName: MASES.KNet.Producer.IKNetProducer.ProduceAndWait(System.String, System.Int32, System.DateTime, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.IKNetProducer(Of K, V).ProduceAndWait(System.String, System.Int32, System.DateTime, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: IKNetProducer.ProduceAndWait(String, Int32, DateTime, K, V, Callback)
+ nameWithType.vb: IKNetProducer(Of K, V).ProduceAndWait(String, Int32, DateTime, K, V, Callback)
+- uid: MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(System.String,System.Int32,System.Int64,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(String, Int32, Int64, K, V, Callback)
+ href: api/MASES.KNet.Producer.IKNetProducer-2.html#MASES_KNet_Producer_IKNetProducer_2_ProduceAndWait_System_String_System_Int32_System_Int64__0__1_Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait(System.String,System.Int32,System.Int64,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName: MASES.KNet.Producer.IKNetProducer.ProduceAndWait(System.String, System.Int32, System.Int64, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.IKNetProducer(Of K, V).ProduceAndWait(System.String, System.Int32, System.Int64, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: IKNetProducer.ProduceAndWait(String, Int32, Int64, K, V, Callback)
+ nameWithType.vb: IKNetProducer(Of K, V).ProduceAndWait(String, Int32, Int64, K, V, Callback)
+- uid: MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait*
+ name: ProduceAndWait
+ href: api/MASES.KNet.Producer.IKNetProducer-2.html#MASES_KNet_Producer_IKNetProducer_2_ProduceAndWait_
+ commentId: Overload:MASES.KNet.Producer.IKNetProducer`2.ProduceAndWait
+ isSpec: "True"
+ fullName: MASES.KNet.Producer.IKNetProducer.ProduceAndWait
+ fullName.vb: MASES.KNet.Producer.IKNetProducer(Of K, V).ProduceAndWait
+ nameWithType: IKNetProducer.ProduceAndWait
+ nameWithType.vb: IKNetProducer(Of K, V).ProduceAndWait
- uid: MASES.KNet.Producer.IKNetProducer`2.ProduceAsync(MASES.KNet.Producer.KNetProducerRecord{`0,`1},System.Action{Org.Apache.Kafka.Clients.Producer.RecordMetadata,MASES.JCOBridge.C2JBridge.JVMBridgeException})
name: ProduceAsync(KNetProducerRecord, Action)
href: api/MASES.KNet.Producer.IKNetProducer-2.html#MASES_KNet_Producer_IKNetProducer_2_ProduceAsync_MASES_KNet_Producer_KNetProducerRecord__0__1__System_Action_Org_Apache_Kafka_Clients_Producer_RecordMetadata_MASES_JCOBridge_C2JBridge_JVMBridgeException__
@@ -18018,6 +18068,56 @@ references:
fullName.vb: MASES.KNet.Producer.KNetProducer(Of K, V).Produce
nameWithType: KNetProducer.Produce
nameWithType.vb: KNetProducer(Of K, V).Produce
+- uid: MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(MASES.KNet.Producer.KNetProducerRecord{`0,`1},Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(KNetProducerRecord, Callback)
+ href: api/MASES.KNet.Producer.KNetProducer-2.html#MASES_KNet_Producer_KNetProducer_2_ProduceAndWait_MASES_KNet_Producer_KNetProducerRecord__0__1__Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(MASES.KNet.Producer.KNetProducerRecord{`0,`1},Org.Apache.Kafka.Clients.Producer.Callback)
+ name.vb: ProduceAndWait(KNetProducerRecord(Of K, V), Callback)
+ fullName: MASES.KNet.Producer.KNetProducer.ProduceAndWait(MASES.KNet.Producer.KNetProducerRecord, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.KNetProducer(Of K, V).ProduceAndWait(MASES.KNet.Producer.KNetProducerRecord(Of K, V), Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: KNetProducer.ProduceAndWait(KNetProducerRecord, Callback)
+ nameWithType.vb: KNetProducer(Of K, V).ProduceAndWait(KNetProducerRecord(Of K, V), Callback)
+- uid: MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(System.String,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(String, K, V, Callback)
+ href: api/MASES.KNet.Producer.KNetProducer-2.html#MASES_KNet_Producer_KNetProducer_2_ProduceAndWait_System_String__0__1_Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(System.String,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName: MASES.KNet.Producer.KNetProducer.ProduceAndWait(System.String, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.KNetProducer(Of K, V).ProduceAndWait(System.String, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: KNetProducer.ProduceAndWait(String, K, V, Callback)
+ nameWithType.vb: KNetProducer(Of K, V).ProduceAndWait(String, K, V, Callback)
+- uid: MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(System.String,System.Int32,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(String, Int32, K, V, Callback)
+ href: api/MASES.KNet.Producer.KNetProducer-2.html#MASES_KNet_Producer_KNetProducer_2_ProduceAndWait_System_String_System_Int32__0__1_Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(System.String,System.Int32,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName: MASES.KNet.Producer.KNetProducer.ProduceAndWait(System.String, System.Int32, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.KNetProducer(Of K, V).ProduceAndWait(System.String, System.Int32, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: KNetProducer.ProduceAndWait(String, Int32, K, V, Callback)
+ nameWithType.vb: KNetProducer(Of K, V).ProduceAndWait(String, Int32, K, V, Callback)
+- uid: MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(System.String,System.Int32,System.DateTime,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(String, Int32, DateTime, K, V, Callback)
+ href: api/MASES.KNet.Producer.KNetProducer-2.html#MASES_KNet_Producer_KNetProducer_2_ProduceAndWait_System_String_System_Int32_System_DateTime__0__1_Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(System.String,System.Int32,System.DateTime,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName: MASES.KNet.Producer.KNetProducer.ProduceAndWait(System.String, System.Int32, System.DateTime, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.KNetProducer(Of K, V).ProduceAndWait(System.String, System.Int32, System.DateTime, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: KNetProducer.ProduceAndWait(String, Int32, DateTime, K, V, Callback)
+ nameWithType.vb: KNetProducer(Of K, V).ProduceAndWait(String, Int32, DateTime, K, V, Callback)
+- uid: MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(System.String,System.Int32,System.Int64,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ name: ProduceAndWait(String, Int32, Int64, K, V, Callback)
+ href: api/MASES.KNet.Producer.KNetProducer-2.html#MASES_KNet_Producer_KNetProducer_2_ProduceAndWait_System_String_System_Int32_System_Int64__0__1_Org_Apache_Kafka_Clients_Producer_Callback_
+ commentId: M:MASES.KNet.Producer.KNetProducer`2.ProduceAndWait(System.String,System.Int32,System.Int64,`0,`1,Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName: MASES.KNet.Producer.KNetProducer.ProduceAndWait(System.String, System.Int32, System.Int64, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ fullName.vb: MASES.KNet.Producer.KNetProducer(Of K, V).ProduceAndWait(System.String, System.Int32, System.Int64, K, V, Org.Apache.Kafka.Clients.Producer.Callback)
+ nameWithType: KNetProducer.ProduceAndWait(String, Int32, Int64, K, V, Callback)
+ nameWithType.vb: KNetProducer(Of K, V).ProduceAndWait(String, Int32, Int64, K, V, Callback)
+- uid: MASES.KNet.Producer.KNetProducer`2.ProduceAndWait*
+ name: ProduceAndWait
+ href: api/MASES.KNet.Producer.KNetProducer-2.html#MASES_KNet_Producer_KNetProducer_2_ProduceAndWait_
+ commentId: Overload:MASES.KNet.Producer.KNetProducer`2.ProduceAndWait
+ isSpec: "True"
+ fullName: MASES.KNet.Producer.KNetProducer.ProduceAndWait
+ fullName.vb: MASES.KNet.Producer.KNetProducer(Of K, V).ProduceAndWait
+ nameWithType: KNetProducer.ProduceAndWait
+ nameWithType.vb: KNetProducer(Of K, V).ProduceAndWait
- uid: MASES.KNet.Producer.KNetProducer`2.ProduceAsync(MASES.KNet.Producer.KNetProducerRecord{`0,`1},System.Action{Org.Apache.Kafka.Clients.Producer.RecordMetadata,MASES.JCOBridge.C2JBridge.JVMBridgeException})
name: ProduceAsync(KNetProducerRecord, Action)
href: api/MASES.KNet.Producer.KNetProducer-2.html#MASES_KNet_Producer_KNetProducer_2_ProduceAsync_MASES_KNet_Producer_KNetProducerRecord__0__1__System_Action_Org_Apache_Kafka_Clients_Producer_RecordMetadata_MASES_JCOBridge_C2JBridge_JVMBridgeException__